2017-07-13 38 views
0

wurstmeisters docker imageからカフカドッカーを作成した後、apache documetnationから手順3,4および5に従って、メッセージを生成し、消費します。残念ながら、そうすることはできません。私は次のエラーを取得するメッセージを送信イム後3秒:Kafkaにメッセージを送信できません

enter image description here

私は与えられたエラーの解決策を見つける傾けます。だから私はこの問題を解決するために何をしなければならないのですか?

ドッカー-compose.yml

version: '2' 
services: 
    zookeeper: 
    image: wurstmeister/zookeeper 
    ports: 
     - "2181:2181" 
    kafka: 
    build: . 
    ports: 
     - "9092:9092" 
    environment: 
     KAFKA_ADVERTISED_HOST_NAME: localhost 
     KAFKA_CREATE_TOPICS: "test:1:1" 
     KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 
    volumes: 
     - /var/run/docker.sock:/var/run/docker.sock 

EDIT

飼育係が到達可能です。

bin/kafka-topics.sh --list --zookeeper localhost:2181 

リターン:

baeldung 
filtered 
greeting 
partitioned 
test 

だから、唯一のブローカーが使用できません。

+0

'--broker-list 120.0.0.1:9092'と' --broker-list 120.0.0.1:9092'を試したことがありますか?また、https://github.com/wurstmeister/kafka-docker/issues/100を見て参考になるかもしれません。 –

+0

なぜ '120.0.0.1:9092'ですか?なぜ同じ時間の2倍のコマンド? – Mulgard

+0

または--broker-list 127.0.0.1:9092'または '--broker-list 0.0.0.0:9092' –

答えて

0

私の意見では、それは非常に奇妙ですが、それはバージョンに起因する単純な競合だったようです。 kafka/wurstmeisterイメージはKafkaバージョンkafka_2.12-0.10.2.1.tgzを使用していますので、コンシューマとプロデューサのクライアントで同じバージョンをダウンロードしました。それが私が上に投稿した結果につながった。

私はバージョンkafka_2.11-0.11.0.0.tgzを試しましたが、すべて正常に動作しています。私はバージョンが動作するように一致する必要があると思ったが、明らかにそうではない。

+0

一致するバージョンが動作するはずです。あなたの問題は何か他のものでなければなりません。 –

関連する問題