Hi Tao,
Sorry, I can't see anything wrong from these logs.
But one thing I'd like to confirm: are you using Kafka directly? Or you're
using Kafka via 3rd party library?
The logs you provided don't look like the logs from Kafka itself. (or it's
because you modified the logs for privacy?)
It'll be b
Thank you Luke,
Here is the logs from client side (rebalance event listener)
2021-12-08 16:30:47,301 INFO com.***.KafkaListener Partition removed from
listener
2021-12-08 16:30:47,302 INFO com.***.KafkaListener Topic:
**InternalLoggingMetadataInfo, partition: 1
2021-12-08 16:30:50,066 INFO com.**
Hi Tao,
I think we need the logs (client and broker side) to know clearly what
happened there.
Besides, I can't see the image you attached under "Consumer Group State
(Please note that app008 is kicked out)" section.
One thing to note is that, we've fixed some bugs related to rebalance and
partit
Hi there,
We have experienced issues on Topic Partition assignment and lead to
duplicate process of event. What happened is that, somehow one listener
(consumer) was taken out by the Broker (lost heartbeat??), and the assigned
partition was taken over by another consumer in the same consumer group
