我从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
所以只有经纪人不在。
1条答案
按热度按时间yv5phkfx1#
在我看来,这是非常奇怪的,但似乎这是一个简单的冲突,由于版本。这个
kafka/wurstmeister
图像使用的是Kafka版本kafka_2.12-0.10.2.1.tgz
当然,我为消费者和生产者客户下载了相同的版本。这导致了我在上面发布的结果。现在我尝试了这个版本
kafka_2.11-0.11.0.0.tgz
一切正常。我认为版本应该匹配工作,但显然不是这样。