Kafka与Docker问题
我试图通过docker-compose文件部署kafka，或者通过安装kafka映像并手动运行它。当我开始运行kafka服务器（代理）时，这两个步骤都给我带来了错误
INFO初始化客户端连接，connectString=188.226.151.167:2181 sessiontimeout=6000 watcher=org.i0itec.zkclient.zkclient@323b36e0(org.apache.zookeeper.zookeeper)[2017-05-16 13:44:49,903]信息等待keeper状态SyncConnected(org.i0itec.zkclient.zkclient)[2017-05-16 13:44:49,909]信息打开到服务器的套接字连接188.226.151.167/188.226.151.167:2181。不会尝试使用SASL（未知错误）(org.apache.zookeeper.clientcnxn)[2017-05-16 13:44:55,904]信息终止ZkClient事件线程进行身份验证。(org.i0itec.zkclient.zkeventThread)
有人能清楚地解释发生了什么以及如何修复它吗
共有1个答案
试试这个：
kafka:
network_mode: 'bridge'
image: wurstmeister/kafka
links:
- zookeeper
environment:
HOSTNAME_COMMAND: "hostname -I | awk -F' ' '{print $$1}'"
KAFKA_ADVERTISED_PORT: 9092
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
zookeeper:
network_mode: 'bridge'
image: wurstmeister/zookeeper
-
问题内容： 我正在尝试使用docker-compose启动kafka服务，并且应该可以在docker内部和外部进行访问。因此，应该在内部和外部设置合适的广告客户： 问题是，当我尝试从群集外部进行连接时，节点名称不是127.0.0.1，而是内部主机名： 这不是KAFKA_ADVERTISED_LISTENERS和KAFKA_LISTENERS处理这种情况的目的吗？我尝试设置KAFKA_ADVERTI
-
https://github.com/confluentinc/cp-docker-images/blob/5.0.0-post/examples/kafka-cluster/docker-compose.yml 我已经编辑了该文件，并将选项添加到docker组合文件中，以便可以在主机之外访问它们。 我已经运行了以下命令： kafka-1、kafka-2、kafka-3的docker日志（均相同）
-
我使用的是Confluent Community 6.0.1。三个节点Kafka集群： devKafka04:Kafka Broker1、Zookeeper 1 开发Kafka05： Kafka经纪人2， 动物园管理员 2 devKafka06：Kafka经纪人3，动物园管理员3 SSL加密已经在Kafka经纪人上运行良好。 我想添加SASL以启用Kafka和Zookeeper之间的相互身份验证。
-
我试图在Windows 10 Pro和Docker桌面上本地运行Kafka（而不是工具箱）。一切似乎都工作得很好，但我无法使用我的应用程序访问Kafka，也没有使用Kafka rest（http://localhost:8082/topics http://127.0.0.1:8082/topics http://192.168.1.103:8082/topics-最后一个是我在主机中的docke
-
我试图连接到Kafka服务器使用SpringKafka客户端 我正在使用logback。xml。下面是配置。在测试之前，我对Kafka主机和端口进行了硬编码。相同的代码和配置适用于其中一个环境。
-
向Kafka推送100,000条消息 在使用者使用所有100,000条消息之前，使用Ctrl-C关闭zookeeper和kafka服务（这是通过在consumer方法中使用来模拟的）。 发现 在zookeeper和kafka服务被关闭后，消费者继续在控制台上写消息。 问题 我如何使消费者从上次消费的消息的索引+1继续。 向Kafka推送100,000条消息 在使用者使用所有100,000条消息之前