Re: Group Coordinator stuck on PrepareRebalance state.

2019-07-16 Thread Aravind Dongara
> Thanks > Thameem > > >> On Jul 11, 2019, at 7:56 PM, Aravind Dongara >> wrote: >> >> Hi Boyang, >> >> Thanks for the quick response. >> We are on version 2.2.0. >> >> We are using the following properties on KStr

Re: Group Coordinator stuck on PrepareRebalance state.

2019-07-11 Thread Aravind Dongara
apache.org/jira/browse/KAFKA-8653 > > and a fix is on its way: https://github.com/apache/kafka/pull/7072/files > > Let me know if you are actually on a different version. > > Boyang > > On Wed, Jul 10, 2019 at 7:43 PM Aravind Dongara > wrote: > >> Our k

Group Coordinator stuck on PrepareRebalance state.

2019-07-10 Thread Aravind Dongara
Our kafka streams application is stuck and continuously emits "(Re-)joining group” log message every 5 minutes without making any progress. Kafka-consumer-groups cmd line tool with “—members” option shows lots of stale members, in addition to expected member-ids shown on log msgs on

Re: KafkaStreams: ProducerFencedException causing StreamThread death

2018-10-01 Thread Aravind Dongara
30, 2018, at 1:17 PM, Guozhang Wang wrote: > > Could you take a look at https://issues.apache.org/jira/browse/KAFKA-7284 > and see if you are hitting this? > > Guozhang > > On Fri, Sep 28, 2018 at 5:22 PM, Aravind Dongara > wrote: > >> Hi Guozhang >>

Re: KafkaStreams: ProducerFencedException causing StreamThread death

2018-09-28 Thread Aravind Dongara
so I want to check if you are using > an older version and if yes, what's the best way to work around it. > > > Guozhang > > > On Thu, Sep 27, 2018 at 12:54 PM, Aravind Dongara < > adong...@yahoo.com.invalid> wrote: > >> >> During a rebalance trigg

KafkaStreams: ProducerFencedException causing StreamThread death

2018-09-27 Thread Aravind Dongara
During a rebalance triggered by kafka-coordinator-heartbeat-thread losing connection to ‘Group coordinator’, we noticed that a stream thread is shutting down when it catches a ProducerFencedExcpetion while flushing the state store. This also causes the stream-state on that node to be stuck in