Kafka Streams & Processor API

2019-08-03 Thread Navneeth Krishnan
Hi All, I'm new to kafka streams and I'm trying to model my use case that is currently written on flink to kafka streams. I have couple of questions. - How can I join two kafka topics using the processor API? I have data stream and change stream which needs to be joined based on a key. - I read

Re: (Re-)joining group for a longer time

2019-08-03 Thread Boyang Chen
Hey Kamesh, thank you for the question. Could you also check the broker side log to see if the group is forming generations properly? Information we have for now is a bit hard to tell what's going on. Also since you have upgraded to 2.3, during incremental rebalancing you will experience 2 rebalan

(Re-)joining group for a longer time

2019-08-03 Thread Kamesh
Hi, I am using Kafka connect cluster for writing data to S3. I have observed, whenever I add a new connector or update the config of an existing connector, I think group balancing is happening and it is affecting all the existing connectors. Rebalancing is happening for all of the existing connect