sclasen akka-kafka issues

sclasen / akka-kafka

185 stars 62 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

What exactly is outstanding?

#57 artmoskvin closed 7 years ago
2
NPE in BatchConnectorFSM

#56 christophercampbell opened 7 years ago
0
Question, how to set SupervisorStrategy for StreamFSM?

#55 kuizhang opened 7 years ago
0
fixed typo: recieve -> receive

#54 mvonthron opened 7 years ago
0
Version in sonatype.org

#53 eugenemiretsky opened 8 years ago
3
Specifying multiple topic

#52 eugenemiretsky opened 8 years ago
1
`unhandled event StartProcessing` Warning

#51 msaffitz opened 8 years ago
0
Multiple workers actors

#50 eugenemiretsky opened 8 years ago
1
New Kafka .9 consumer

#49 dtboctor opened 8 years ago
3
Can AkkaConsumber inherit from a common base trait?

#48 coreyauger opened 8 years ago
2
Guidance Requested: Error Handling

#47 msaffitz closed 8 years ago
2
stop should return future before shutdown

#46 coreyauger closed 8 years ago
3
Highlevel consumer using executor

#45 sclasen opened 8 years ago
1
AkkaHighLevelConsumer additions

#44 coreyauger closed 8 years ago
23
ConsumerTimeoutException

#43 mjuchli closed 8 years ago
5
Batch consumer priority

#42 haritsE closed 8 years ago
2
Unable to cleanly stop AkkaConsumer

#41 ulejon closed 8 years ago
1
Empty Queue

#40 sebastian-alfers opened 9 years ago
1
Race / off-by-one issue in BatchFSM? (Stuck temporarily in WaitingToSendBatch)

#39 jbweeks closed 8 years ago
3
No license explicitly stated

#38 esammer opened 9 years ago
2
Question : How can I consume my kafka topic as fast as possible ?

#37 pocman opened 9 years ago
22
remove unused imports

#36 xuwei-k closed 8 years ago
1
add travis-ci settings

#35 xuwei-k closed 8 years ago
0
Consumer with a Router

#34 salex89 closed 9 years ago
5
StateTimeout after 1 message is processed

#33 romangarcia closed 9 years ago
7
Any reason for losing the key

#32 radekg closed 9 years ago
2
StateTimeout with long processing

#31 salex89 closed 9 years ago
7
kafka 0820 akka 239

#30 sclasen closed 9 years ago
1
Example in the readme not working

#29 kiran-kumar closed 8 years ago
2
Question about zero tolerance for message loss

#28 kiran-kumar closed 9 years ago
3
Question about state on the stream

#27 richiesgr closed 9 years ago
3
Question : I try to use it but nothing ...

#26 richiesgr closed 9 years ago
7
Added timeout to unused state

#25 kuhnen closed 3 years ago
3
Make supervision possible

#24 tylerholien closed 9 years ago
1
Unused state does not try again

#23 kuhnen opened 9 years ago
3
Question: Consuming from start of a topic

#22 sergmor closed 9 years ago
3
fixed println and typo

#21 dyk closed 9 years ago
1
Scala 2.11 / Akka 2.3.6 artifact

#20 AlexeyRaga closed 9 years ago
7
warn or error when kafka consumer timeout > batch timeout

#19 sclasen opened 9 years ago
0
0.8.2-beta not working

#18 joestein closed 9 years ago
8
Implementing topic offset

#17 tnolet closed 9 years ago
10
could you publish 0.0.8-SNAPSHOT

#16 eodgooch closed 9 years ago
3
Specify receiver as Props instead of ActorRef?

#15 tarmath closed 9 years ago
3
consumer read from specific partition

#14 joshjdevl closed 10 years ago
4
(low priority) Coda Hale Metrics for topic offset, stream metrics

#13 jbweeks opened 10 years ago
2
Batch consumer

#12 sclasen closed 10 years ago
0
how do I configure the offset?

#11 xelax closed 10 years ago
4
Race issues with StreamFSM when sending a batch of Processed messages

#10 jbweeks closed 10 years ago
38
add a message handler function

#9 sclasen closed 10 years ago
0
Feature Request: option to return message metadata (e.g. msg key) to consumer

#8 jbweeks closed 10 years ago
6