問題タブ [sarama]
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.
go - kafka サーバー: オフセットのトピックはまだ作成されていません
Kafka サーバー 0.9 + Zookeper を使用しています。私はカフカが初めてです。virtualbox で実行されており、パブリック IP を使用して接続できるため、機能しています...多かれ少なかれ: トピックとメッセージを取得できます。だから今のところ私は2つの問題があります:
__consumer_offsets (空) で何も見つからないため、go simple consumer スクリプトでエラーをスローする問題が発生しました:
kafka server: Offset's topic has not yet been created
; コマンドでzookeeper-shell.shコンソールをチェックするls /brokers/topics/__consumer_offsets
と、エラーが発生します:Node does not exist: /brokers/topics/__consumer_offsets
(接続されている可能性があります) トピックの自動作成時に軽微な警告が表示されました:
WARN NetworkClient - Error while fetching metadata with correlation id 4157 : {topicName=LEADER_NOT_AVAILABLE}
どんな助けでも大歓迎です。ありがとう!