Sean Glover
Sean Glover
Maybe you could investigate this in #2575, or a separate PR?
@HariSekhon Thanks for the reply. I re-ran a Travis job and it doesn't seem to have made a difference. We don't have Travis setup to cache docker images, so it...
Hi @HariSekhon. Were you able to run your testsuites yet?
I haven't been able to reproduce this flakiness on master, only #1103.
Nevermind, I just did, though it seems to happen less frequently. The symptom is that the transactional source gets stuck in a loop checking for inflight messages to be committed...
Looks like I broke exactly once consistency checks somehow. I'll take a look at some point today, but this might not be ready for 2.0.3.
New failure: https://travis-ci.org/github/akka/alpakka-kafka/jobs/691735521#L386
@huntc I agree that would be useful. The Alpakka Kafka JUnit testkit doesn't subclass or encapsulate an Akka testkit like the Alpakka Kafka Scala testkit does. We could explore changing...
Hi @gmarti. This is likely related to the `stop-timeout` setting on the consumer, which is 30s by default. We've discussed setting this configuration to `0` for transactional workloads or removing...
> The current behavior seems to open a new transaction just after committing even if it will not be used. Is there an "after transaction" timeout or something ? Yes,...