Enno Runne

Results 342 comments of Enno Runne

You mean the ugly use of an `AtomicReference`? That problem is not specific to the transactional flows. It would be great to come up with some better API for this...

Let's try and get more information on the scenarios where committing times out. Please report the version of the Alpakka Kafka connector/Reactive Kafka and the version of the Kafka cluster....

@mohnishkodnani The situation with the AskTimeException during commit from 0.13 has been vastly improved. I hope you will be able to upgrade Kafka and the Alpakka Kafka connector soon.

Do you have problems with timeouts on committing while using autocommit?

Thank you for more details on this. I've just merged better exposure of errors from the Kafka client into the streams (see #617) which will help to inspect such failures...

Interesting findings @kciesielski I'd like to encourage you to try with a 1.0-RC version, we consider them as viable as the earlier 0.x versions.

Thank you for trying the latest milestones out so eagerly. We haven't changed anything in this area, so it could be expected to still see this failure. It would be...

Thank you for this suggestion. The resolution of config doesn't allow us to put an `application.conf` to overwrite other settings in Alpakka Kafka. I've however added some text to the...

Configuration can be inherited on config level: ``` MyConsumerConfigInTests: ${akka.kafka.consumer} { stop-timeout = 2s } ``` But please, go ahead and suggest improvements to the docs.

Thank you for discussing this here. Reordering of messages and thus committing offsets wrong causes nasty bugs and Alpakka Kafka can get better at avoiding it. For case 1. I...