2016-08-24 1 views
0

2台の独立したマシンkafkaを実行するために、2台のマシンlocalhostと192.168.1.110があります。は、消費者またはプロデューサでkafka broker ipを使用できますか?

(1)ローカルホストでは、私が実行します。

➜kafka_2.11-0.10.0.0ビン/ kafka-console-producer.sh --brokerリスト192.168.1.110:9092 --topicテスト この鍵とトピックテストにメッセージを送信するエラーエラー:ヌル値:エラーで2バイト:(org.apache.kafka.clients.producer.internals.ErrorLoggingCallbackメッセージ 【:15 27441 2016年8月24日18]であります) org.apache.kafka.common.errors.TimeoutException:テスト0のブローカからメタデータを要求中にタイムアウトにより1レコードが含まれているバッチ

メッセージをブローカ192.168に送信できない理由1.110? 私は消費者またはプロデューサで直接ブローカーのIPを使用できますか? 私はhostnameだけを使用できましたが、これはadvertised.host.nameに関連していますか? 次に、advertised.host.nameを設定する方法は?このホスト名は世界的に解決できる必要がありません(私はホスト名を解決するには、/ etc/hostsファイルを使用することができます?)

(2) 私はその後、私は実行192.168.1.110、 にlocalhostのポイントをできるように/ etc/hostsファイルを編集しました: ➜kafka_2.11-0.10.0.0 bin/kafka-console-producer.sh --broker-list localhost:9092 --topicテスト

私は正常に192.168.1.110にメッセージを送信し、そこのメッセージを消費することができました。

(3)私は、私が実行192.168.1.110、 にrrlocalhostポイントをできるように/ etc/hostsファイルを編集した: ➜kafka_2.11-0.10.0.0ビン/ kafka-console-producer.sh --brokerリストをrrlocalhost:9092 --topic試験

私は(1)と同じエラーがある、rrlocalhostするメッセージを送りました。

答えて

1

間違いなく直接IPアドレスを使用することができます。

ブローカーの設定advertised.host.nameは、飼育係に登録され、生産者と消費者は、クラスタメタデータとしてそれらを取得します。ローカルニックネームを使用して設定すると、プロデューサとコンシューマは通信できません。

関連する問題