Ich konnte keine Nachrichten an Kafka senden

Question

Ich habe einen Kafka-Docker von wurstmeisters docker image erstellt und danach die Schritte 3, 4 und 5 von apache documetnation ausgeführt, um Nachrichten zu erstellen und zu konsumieren. Leider ist das nicht möglich. 3 Sekunden nach dem im Senden einer Nachricht, die ich die folgende Fehlermeldung erhalten:

Ich kann Lösungen für den gegebenen Fehler finden. Was muss ich tun, um dieses Problem zu lösen?

Docker-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

Der Zoowärter erreichbar ist.

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

kehrt:

baeldung 
filtered 
greeting 
partitioned 
test 

So nur ist der Broker nicht zur Verfügung.

Answer 1

Meiner Meinung nach ist es sehr seltsam, aber es scheint, dass es ein einfacher Konflikt aufgrund der Version war. Das Bild verwendet die Kafka-Version kafka_2.12-0.10.2.1.tgz, also habe ich natürlich die gleiche Version für die Consumer- und Producer-Clients heruntergeladen. Das führte zu dem Ergebnis, das ich oben gepostet habe.

Jetzt habe ich versucht, die Version kafka_2.11-0.11.0.0.tgz und alles funktioniert gut. Ich dachte, die Versionen sollten funktionieren, aber das ist offensichtlich nicht der Fall.