Re: ProducerFencedException: Producer attempted an operation with an old epoch.

2018-02-14 Thread Matthias J. Sax
We discovered and fixed some bugs in upcoming 1.0.1 and 1.1.0 releases. Maybe you can try those out? A ProducerFenced Exception should actually be self-healing and resolve over time. How long did the application retry to rebalance? Without logs, its hard to tell what might cause the issue

ProducerFencedException: Producer attempted an operation with an old epoch.

2018-02-08 Thread dan bress
Hi, I recently switched my Kafka Streams 1.0.0 app to use exactly_once semantics and since them my cluster has been stuck in rebalancing. Is there an explanation as to what is going on, or how I can resolve it? I saw a similar issue discussed on the mailing list, but I don't know if a ticket