sclasen/akka-kafka issues and pull requests

#57 - What exactly is outstanding?

Issue - State: closed - Opened by artmoskvin over 7 years ago - 2 comments

#56 - NPE in BatchConnectorFSM

Issue - State: open - Opened by christophercampbell over 7 years ago

#55 - Question, how to set SupervisorStrategy for StreamFSM?

Issue - State: open - Opened by kuizhang almost 8 years ago

#54 - fixed typo: recieve -> receive

Pull Request - State: open - Opened by mvonthron almost 8 years ago

#53 - Version in sonatype.org

Issue - State: open - Opened by eugenemiretsky over 8 years ago - 3 comments

#53 - Version in sonatype.org

Issue - State: open - Opened by eugenemiretsky over 8 years ago - 3 comments

#52 - Specifying multiple topic

Issue - State: open - Opened by eugenemiretsky over 8 years ago - 1 comment

#52 - Specifying multiple topic

Issue - State: open - Opened by eugenemiretsky over 8 years ago - 1 comment

#51 - `unhandled event StartProcessing` Warning

Issue - State: open - Opened by msaffitz over 8 years ago

#51 - `unhandled event StartProcessing` Warning

Issue - State: open - Opened by msaffitz over 8 years ago

#50 - Multiple workers actors

Issue - State: open - Opened by eugenemiretsky over 8 years ago - 1 comment

#50 - Multiple workers actors

Issue - State: open - Opened by eugenemiretsky over 8 years ago - 1 comment

#49 - New Kafka .9 consumer

Issue - State: open - Opened by dtboctor over 8 years ago - 3 comments

#49 - New Kafka .9 consumer

Issue - State: open - Opened by dtboctor over 8 years ago - 3 comments

#48 - Can AkkaConsumber inherit from a common base trait?

Issue - State: open - Opened by coreyauger over 8 years ago - 2 comments

#48 - Can AkkaConsumber inherit from a common base trait?

Issue - State: open - Opened by coreyauger over 8 years ago - 2 comments

#47 - Guidance Requested: Error Handling

Issue - State: closed - Opened by msaffitz over 8 years ago - 2 comments

#47 - Guidance Requested: Error Handling

Issue - State: closed - Opened by msaffitz over 8 years ago - 2 comments

#46 - stop should return future before shutdown

Pull Request - State: closed - Opened by coreyauger over 8 years ago - 3 comments

#46 - stop should return future before shutdown

Pull Request - State: closed - Opened by coreyauger over 8 years ago - 3 comments

#45 - Highlevel consumer using executor

Pull Request - State: open - Opened by sclasen over 8 years ago - 1 comment

#44 - AkkaHighLevelConsumer additions

Pull Request - State: closed - Opened by coreyauger over 8 years ago - 23 comments

#44 - AkkaHighLevelConsumer additions

Pull Request - State: closed - Opened by coreyauger over 8 years ago - 23 comments

#43 - ConsumerTimeoutException

Issue - State: closed - Opened by mjuchli almost 9 years ago - 5 comments

#43 - ConsumerTimeoutException

Issue - State: closed - Opened by mjuchli almost 9 years ago - 5 comments

#42 - Batch consumer priority

Issue - State: closed - Opened by haritsE almost 9 years ago - 2 comments

#42 - Batch consumer priority

Issue - State: closed - Opened by haritsE almost 9 years ago - 2 comments

#41 - Unable to cleanly stop AkkaConsumer

Issue - State: closed - Opened by ulejon about 9 years ago - 1 comment

#41 - Unable to cleanly stop AkkaConsumer

Issue - State: closed - Opened by ulejon about 9 years ago - 1 comment

#40 - Empty Queue

Issue - State: open - Opened by sebastian-alfers about 9 years ago - 1 comment

#40 - Empty Queue

Issue - State: open - Opened by sebastian-alfers about 9 years ago - 1 comment

#39 - Race / off-by-one issue in BatchFSM? (Stuck temporarily in WaitingToSendBatch)

Issue - State: closed - Opened by jbweeks about 9 years ago - 3 comments

#39 - Race / off-by-one issue in BatchFSM? (Stuck temporarily in WaitingToSendBatch)

Issue - State: closed - Opened by jbweeks about 9 years ago - 3 comments

#38 - No license explicitly stated

Issue - State: open - Opened by esammer over 9 years ago - 2 comments

#38 - No license explicitly stated

Issue - State: open - Opened by esammer over 9 years ago - 2 comments

#37 - Question : How can I consume my kafka topic as fast as possible ?

Issue - State: open - Opened by pocman over 9 years ago - 22 comments

#37 - Question : How can I consume my kafka topic as fast as possible ?

Issue - State: open - Opened by pocman over 9 years ago - 22 comments

#36 - remove unused imports

Pull Request - State: closed - Opened by xuwei-k over 9 years ago - 1 comment

#35 - add travis-ci settings

Pull Request - State: closed - Opened by xuwei-k over 9 years ago

#35 - add travis-ci settings

Pull Request - State: closed - Opened by xuwei-k over 9 years ago

#34 - Consumer with a Router

Issue - State: closed - Opened by salex89 over 9 years ago - 5 comments

#34 - Consumer with a Router

Issue - State: closed - Opened by salex89 over 9 years ago - 5 comments

#33 - StateTimeout after 1 message is processed

Issue - State: closed - Opened by romangarcia over 9 years ago - 7 comments

#33 - StateTimeout after 1 message is processed

Issue - State: closed - Opened by romangarcia over 9 years ago - 7 comments

#32 - Any reason for losing the key

Issue - State: closed - Opened by radekg over 9 years ago - 2 comments

#32 - Any reason for losing the key

Issue - State: closed - Opened by radekg over 9 years ago - 2 comments

#31 - StateTimeout with long processing

Issue - State: closed - Opened by salex89 over 9 years ago - 7 comments

#31 - StateTimeout with long processing

Issue - State: closed - Opened by salex89 over 9 years ago - 7 comments

#30 - kafka 0820 akka 239

Pull Request - State: closed - Opened by sclasen over 9 years ago - 1 comment

#30 - kafka 0820 akka 239

Pull Request - State: closed - Opened by sclasen over 9 years ago - 1 comment

#29 - Example in the readme not working

Issue - State: closed - Opened by kiran-kumar over 9 years ago - 2 comments

#29 - Example in the readme not working

Issue - State: closed - Opened by kiran-kumar over 9 years ago - 2 comments

#28 - Question about zero tolerance for message loss

Issue - State: closed - Opened by kiran-kumar over 9 years ago - 3 comments

#28 - Question about zero tolerance for message loss

Issue - State: closed - Opened by kiran-kumar over 9 years ago - 3 comments

#27 - Question about state on the stream

Issue - State: closed - Opened by richiesgr over 9 years ago - 3 comments

#27 - Question about state on the stream

Issue - State: closed - Opened by richiesgr over 9 years ago - 3 comments

#26 - Question : I try to use it but nothing ...

Issue - State: closed - Opened by richiesgr over 9 years ago - 7 comments

#26 - Question : I try to use it but nothing ...

Issue - State: closed - Opened by richiesgr over 9 years ago - 7 comments

#25 - Added timeout to unused state

Pull Request - State: closed - Opened by kuhnen over 9 years ago - 3 comments

#24 - Make supervision possible

Pull Request - State: closed - Opened by tylerholien over 9 years ago - 1 comment

#24 - Make supervision possible

Pull Request - State: closed - Opened by tylerholien over 9 years ago - 1 comment

#23 - Unused state does not try again

Issue - State: open - Opened by kuhnen almost 10 years ago - 3 comments

#23 - Unused state does not try again

Issue - State: open - Opened by kuhnen almost 10 years ago - 3 comments

#22 - Question: Consuming from start of a topic

Issue - State: closed - Opened by sergmor almost 10 years ago - 3 comments

#22 - Question: Consuming from start of a topic

Issue - State: closed - Opened by sergmor almost 10 years ago - 3 comments

#21 - fixed println and typo

Pull Request - State: closed - Opened by dyk almost 10 years ago - 1 comment

#21 - fixed println and typo

Pull Request - State: closed - Opened by dyk almost 10 years ago - 1 comment

#20 - Scala 2.11 / Akka 2.3.6 artifact

Issue - State: closed - Opened by AlexeyRaga almost 10 years ago - 7 comments

#20 - Scala 2.11 / Akka 2.3.6 artifact

Issue - State: closed - Opened by AlexeyRaga almost 10 years ago - 7 comments

#19 - warn or error when kafka consumer timeout > batch timeout

Issue - State: open - Opened by sclasen almost 10 years ago

#19 - warn or error when kafka consumer timeout > batch timeout

Issue - State: open - Opened by sclasen almost 10 years ago

#18 - 0.8.2-beta not working

Issue - State: closed - Opened by joestein almost 10 years ago - 8 comments

#18 - 0.8.2-beta not working

Issue - State: closed - Opened by joestein almost 10 years ago - 8 comments

#17 - Implementing topic offset

Issue - State: closed - Opened by tnolet almost 10 years ago - 10 comments

#17 - Implementing topic offset

Issue - State: closed - Opened by tnolet almost 10 years ago - 10 comments

#16 - could you publish 0.0.8-SNAPSHOT

Issue - State: closed - Opened by eodgooch almost 10 years ago - 3 comments

#16 - could you publish 0.0.8-SNAPSHOT

Issue - State: closed - Opened by eodgooch almost 10 years ago - 3 comments

#15 - Specify receiver as Props instead of ActorRef?

Issue - State: closed - Opened by tarmath almost 10 years ago - 3 comments

#15 - Specify receiver as Props instead of ActorRef?

Issue - State: closed - Opened by tarmath almost 10 years ago - 3 comments

#14 - consumer read from specific partition

Issue - State: closed - Opened by joshjdevl about 10 years ago - 4 comments

#14 - consumer read from specific partition

Issue - State: closed - Opened by joshjdevl about 10 years ago - 4 comments

#13 - (low priority) Coda Hale Metrics for topic offset, stream metrics

Issue - State: open - Opened by jbweeks about 10 years ago - 2 comments

#13 - (low priority) Coda Hale Metrics for topic offset, stream metrics

Issue - State: open - Opened by jbweeks about 10 years ago - 2 comments

#12 - Batch consumer

Pull Request - State: closed - Opened by sclasen about 10 years ago

#12 - Batch consumer

Pull Request - State: closed - Opened by sclasen about 10 years ago

#11 - how do I configure the offset?

Issue - State: closed - Opened by xelax about 10 years ago - 4 comments

#11 - how do I configure the offset?

Issue - State: closed - Opened by xelax about 10 years ago - 4 comments

#10 - Race issues with StreamFSM when sending a batch of Processed messages

Issue - State: closed - Opened by jbweeks about 10 years ago - 38 comments

#10 - Race issues with StreamFSM when sending a batch of Processed messages

Issue - State: closed - Opened by jbweeks about 10 years ago - 38 comments

#9 - add a message handler function

Pull Request - State: closed - Opened by sclasen about 10 years ago

#8 - Feature Request: option to return message metadata (e.g. msg key) to consumer

Issue - State: closed - Opened by jbweeks about 10 years ago - 6 comments

#8 - Feature Request: option to return message metadata (e.g. msg key) to consumer

Issue - State: closed - Opened by jbweeks about 10 years ago - 6 comments

#7 - Fix travis

Pull Request - State: closed - Opened by sclasen about 10 years ago

#6 - Fix travis

Pull Request - State: closed - Opened by sclasen about 10 years ago

#6 - Fix travis

Pull Request - State: closed - Opened by sclasen about 10 years ago

#5 - first snapshot of using a TopicFilter

Pull Request - State: closed - Opened by sclasen about 10 years ago - 9 comments

#5 - first snapshot of using a TopicFilter

Pull Request - State: closed - Opened by sclasen about 10 years ago - 9 comments

GitHub / sclasen/akka-kafka issues and pull requests