There could be duplicated consumptions when there are multiple workers in the same consume group.
The worker stops heartbeat first when shutting down, and then flush checkpoint. Other worker may acquire the outdated checkpoint and consume duplicated logs.
There could be duplicated consumptions when there are multiple workers in the same consume group. The worker stops heartbeat first when shutting down, and then flush checkpoint. Other worker may acquire the outdated checkpoint and consume duplicated logs.