問題タブ [confluent-kafka-python]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

114 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
1 に答える
1053 参照

apache-kafka - Kafka コンシューマが再起動後に最後にコミットされたオフセットから消費しない

サブスクライブされたトピックからの消費者ポーリングがあります。各メッセージを消費し、(数秒以内に) 何らかの処理を行い、別のトピックにプッシュし、オフセットをコミットします。

全部で 5000 件のメッセージがあり、

再起動前 - 2900 メッセージを消費し、オフセットをコミットしました

再起動後 - オフセット 0 から消費を開始しました。

コンシューマーは同じコンシューマー グループで作成されますが、オフセット 0 からメッセージの処理を開始しました。

kafka バージョン (strimzi) > 2.0.0 kafka-python == 2.0.1


12345678910