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}
どんな助けでも大歓迎です。ありがとう！