在MacOS上实现卡夫卡的失败
提问于 2017-06-27 17:02:11
我正在我的mac机上运行一个被篡改的卡夫卡(MacOS塞拉利昂(10.12.2))，但失败了。我有DockerforMacVersion17.03.1-ce，构建c6d412e。这些是我用的图像。
我遵循官方快速启动指南中的建议，使用以下命令运行Zookeeper和Kafka。
docker run -d \
--net=host \
--name=zookeeper \
-e ZOOKEEPER_CLIENT_PORT=32181 \
confluentinc/cp-zookeeper:3.2.1
docker run -d \
--net=host \
--name=kafka \
-e KAFKA_ZOOKEEPER_CONNECT=localhost:32181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:29092 \
confluentinc/cp-kafka:3.2.1MAIN，否则它不适用于docker-。同样，它在我的mac上，1.11.2版本，构建dfed245。
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:3.2.2
environment:
- ZOOKEEPER_CLIENT_PORT=2181
ports:
- 2181:2181
kafka:
image: confluentinc/cp-kafka:3.2.2
environment:
- KAFKA_BROKER_ID=0
- KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
- KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092
- KAFKA_AUTO_CREATE_TOPICS_ENABLE=true
ports:
- 9092:9092
- 8082:8082
depends_on:
- zookeeper服务将启动，我甚至可以使用这些命令创建一个主题。
kafka-topics --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test
kafka-topics --list --zookeeper zookeeper:2181当我试图用这个命令进行生产时，动物园管理员保持沉默。
kafka-console-producer --broker-list kafka:9092 --topic test
message-one
message-two当我尝试使用以下命令时：
kafka-console-consumer --bootstrap-server zookeeper:2181 --topic test --from-beginning。。动物园管理员不断地吐出这个错误：
...
zookeeper_1 | [2017-06-28 00:55:07,222] INFO Accepted socket connection from /172.20.0.3:52124 (org.apache.zookeeper.server.NIOServerCnxnFactory)
zookeeper_1 | [2017-06-28 00:55:07,222] WARN Exception causing close of session 0x0 due to java.io.EOFException (org.apache.zookeeper.server.NIOServerCnxn)
zookeeper_1 | [2017-06-28 00:55:07,223] INFO Closed socket connection for client /172.20.0.3:52124 (no session established for client) (org.apache.zookeeper.server.NIOServerCnxn)
...
回答 1
Stack Overflow用户
回答已采纳
发布于 2017-06-27 19:46:40
您为新的控制台使用者指定了错误的主机和端口。试试console-consumer --bootstrap-server kafka:9092 --topic test --from-beginning
另外，如果您从外部(即本机macOS主机上)运行这些命令，那么编辑/etc/host文件，将kafka和Zoo门将添加为本地主机的别名
您还可能希望声明并挂载动物园管理员和kafka日志的外部卷，这样，如果您销毁了码头映像并升级到新版本，您的数据就不会丢失。
Confluent为这些图像提供了完整的QuickStart文档，这里是http://docs.confluent.io/current/cp-docker-images/docs/quickstart.html
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/44792120
复制相关文章
腾讯云开发者
