无法向Kafka发送消息

flmtquvp  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(306)

我从wurstmeisters docker映像创建了一个kafka docker,然后按照apache Documentation的步骤3、4和5生成和使用消息。不幸的是,这样做是不可能的。在我发送消息3秒钟后,我收到以下错误:

我找不到解决给定错误的方法。那我该怎么解决这个问题呢?
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

编辑
Zookeeper是可以联系到的。

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

退货:

baeldung
filtered
greeting
partitioned
test

所以只有经纪人不在。

yv5phkfx

yv5phkfx1#

在我看来,这是非常奇怪的,但似乎这是一个简单的冲突,由于版本。这个 kafka/wurstmeister 图像使用的是Kafka版本 kafka_2.12-0.10.2.1.tgz 当然,我为消费者和生产者客户下载了相同的版本。这导致了我在上面发布的结果。
现在我尝试了这个版本 kafka_2.11-0.11.0.0.tgz 一切正常。我认为版本应该匹配工作,但显然不是这样。

相关问题