search

sclasen / akka-kafka

185 stars 62 forks source link

Added timeout to unused state #25

Closed kuhnen closed 3 years ago

kuhnen commented 9 years ago

This commit solves the problem when kafka and the consumer is not commiting and goes to the unused state. Please let me know if I can improve anything in the code. After this commit is accepted I want to merge this change with the kafka-082 branch and do some upgrade on the akka libraries.

sclasen commented 9 years ago

@kuhnen looks good!

mind adding the same 'behavior' to the 'Batch' side? BatchConnectorFSM/BatchStreamFSM

kuhnen commented 9 years ago

@sclasen I will add the behavior as soon as I can, this week I will be a little busy, but I try make the change before next monday

sclasen commented 9 years ago

Thanks! no rush.

On Mon, Jan 12, 2015 at 2:33 PM, Andre Kuhnen notifications@github.com wrote:

@sclasen https://github.com/sclasen I will add the behavior as soon as I can, this week I will be a little busy, but I try make the change before next monday

— Reply to this email directly or view it on GitHub https://github.com/sclasen/akka-kafka/pull/25#issuecomment-69660203.