問題タブ [strimzi]

質問する

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.

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

apache-kafka - camel を使用して Kafka に接続できません

キャメル カフカ コンポーネントを使用してカフカ クラスターに接続しています。アプリケーションの起動時に以下のエラーが表示されます。これらのエラーの意味を教えてください。クライアントがブートストラップ サーバーに接続できないことは確かです。ブートストラップ サーバーの IP とポートを意図的にマスクしました

私のソフトウェアレベルは

  • ラクダ: 3.1.0
  • カフカ クライアント: 2.5.0

Kafka クラスタ レベル

  • ストリムジ -0.18.0
  • カフカ: 2.5.0
0 投票する
1 に答える
1053 参照

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

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

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

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

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

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

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


12345678910