問題タブ [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.

0 投票する
2 に答える
4657 参照

go - kafka サーバー: オフセットのトピックはまだ作成されていません

Kafka サーバー 0.9 + Zookeper を使用しています。私はカフカが初めてです。virtualbox で実行されており、パブリック IP を使用して接続できるため、機能しています...多かれ少なかれ: トピックとメッセージを取得できます。だから今のところ私は2つの問題があります:

  1. __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

  2. (接続されている可能性があります) トピックの自動作成時に軽微な警告が表示されました:WARN NetworkClient - Error while fetching metadata with correlation id 4157 : {topicName=LEADER_NOT_AVAILABLE}

どんな助けでも大歓迎です。ありがとう!