Hi,
I have debugged the problem further and looks like something is not right.
Here are the logs from one of the thread
stream-thread [StreamThread-3] Committing all tasks because the commit
interval 3ms has elapsed
stream-thread [StreamThread-3] Committing task 0_0
stream-thread [StreamThrea
Hi All,
We some time get errors like this:
org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be
completed since the group has already rebalanced and assigned the
partitions to another member. This means that the time between subsequent
calls to poll() was longer than the config
