サブスクライブされたトピックからの消費者ポーリングがあります。各メッセージを消費し、(数秒以内に) 何らかの処理を行い、別のトピックにプッシュし、オフセットをコミットします。
全部で 5000 件のメッセージがあり、
再起動前 - 2900 メッセージを消費し、オフセットをコミットしました
再起動後 - オフセット 0 から消費を開始しました。
コンシューマーは同じコンシューマー グループで作成されますが、オフセット 0 からメッセージの処理を開始しました。
kafka バージョン (strimzi) > 2.0.0 kafka-python == 2.0.1