Enno Runne
Enno Runne
If you're willing to try this out that would be great.
Thank you for reporting what you experienced. What versions are you using? Can you explain your findings more exact? Only offsets of successfully produced records are added to be committed....
Yes, you are right. `committableSink` will allow committing of offsets out of order if the producer callbacks finish in a different order than the `send` was issued.
What version of the Alpakka Kafka connector do you use?
I'm not sure I understand what exactly you are experiencing. What do you mean with "read any message, or no messages anymore"? Can you give release 0.22 a spin, please?
The log messages both of you sent are from the Apache Kafka client library. I'm not sure, but I believe the client doesn't signal `coordinator dead` upwards so there is...
Thank you for this report! I guess it is hard to create a reproducer for this, but it would be immensely helpful when trying to fix this.
We haven't seen reports of any similar problems. It could be a problem with how you implemented committing. Please upgrade to the latest version and start using the provided [Committer.sink...
That is weird, indeed. Do you use commit refreshing? (configured by `commit-refresh-interval`) See last paragraph of section https://doc.akka.io/docs/alpakka-kafka/current/consumer.html#committer-sink
`commit-refresh-interval=infinite` means the feature is disabled. A possibly related change that comes to my mind is the stashing of commits during re-balance https://github.com/akka/alpakka-kafka/pull/751