首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
社区首页 >问答首页 >在MacOS上实现卡夫卡的失败

在MacOS上实现卡夫卡的失败
EN

Stack Overflow用户
提问于 2017-06-28 01:02:11
回答 1查看 794关注 0票数 0

我正在我的mac机上运行一个被篡改的卡夫卡(MacOS塞拉利昂(10.12.2)),但失败了。我有DockerforMacVersion17.03.1-ce,构建c6d412e。这些是我用的图像。

我遵循官方快速启动指南中的建议,使用以下命令运行Zookeeper和Kafka。

代码语言:javascript
代码运行次数:0
运行
复制
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.1

MAIN,否则它不适用于docker-。同样,它在我的mac上,1.11.2版本,构建dfed245。

代码语言:javascript
代码运行次数:0
运行
复制
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

服务将启动,我甚至可以使用这些命令创建一个主题。

代码语言:javascript
代码运行次数:0
运行
复制
kafka-topics --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic test
kafka-topics --list --zookeeper zookeeper:2181

当我试图用这个命令进行生产时,动物园管理员保持沉默。

代码语言:javascript
代码运行次数:0
运行
复制
kafka-console-producer --broker-list kafka:9092 --topic test
message-one
message-two

当我尝试使用以下命令时:

代码语言:javascript
代码运行次数:0
运行
复制
kafka-console-consumer --bootstrap-server zookeeper:2181 --topic test --from-beginning

。。动物园管理员不断地吐出这个错误:

代码语言:javascript
代码运行次数:0
运行
复制
...
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)
...
EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2017-06-28 03: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

票数 3
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/44792120

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档