无法使用Docker容器中的Kafka代理运行控制台使用者

Question

我可以从命令行运行Zookeeper和Kafka代理，成功地生成和使用消息。当我使用Zookeeper构建docker容器时，我可以使用从命令行运行的Kafka代理来运行它，再次成功地生成和使用消息。当我将代理放入docker容器中时，消费者和生产者就找不到可以连接到的代理。

我已经检查以确保Zookeeper有一个连接的代理：下面的Zookeeper“dump”命令

echo dump | nc localhost 2181

退货

SessionTracker dump:
Session Sets (3)/(1):
0 expire at Thu May 28 09:53:33 GMT 2020:
0 expire at Thu May 28 09:53:36 GMT 2020:
1 expire at Thu May 28 09:53:39 GMT 2020:
    0x10002dfed700008
ephemeral nodes dump:
Sessions with Ephemerals (1):
0x10002dfed700008:
    /controller
    /brokers/ids/0
Connections dump:
Connections Sets (2)/(2):
0 expire at Thu May 28 09:53:37 GMT 2020:
2 expire at Thu May 28 09:53:47 GMT 2020:
    ip: /172.18.0.1:55656 sessionId: 0x0
    ip: /172.18.0.5:48474 sessionId: 0x10002dfed700008

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

netstat -plnt

我可以看到我在端口2181和9092上有监听器，如下所示

tcp6       0      0 :::9092                 :::*                    LISTEN      54661/docker-proxy
tcp6       0      0 :::2181                 :::*                    LISTEN      47872/docker-proxy 

但是，当我尝试用命令连接使用者时

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic aaaa

我有错误

WARN [Consumer clientId=consumer-console-consumer-8228-1, groupId=console-consumer-8228] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)

Answer 1

请确保配置以下内容：

KAFKA_LISTENERS: LISTENER_INTERNAL://kafka-host:29092,LISTENER_EXTERNAL://kafka-host:9092
KAFKA_ADVERTISED_LISTENERS: LISTENER_INTERNAL://kafka-host:29092,LISTENER_EXTERNAL://localhost:9092
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: LISTENER_INTERNAL:PLAINTEXT,LISTENER_EXTERNAL:PLAINTEXT
KAFKA_INTER_BROKER_LISTENER_NAME: LISTENER_INTERNAL

>

现在，在Docker网络中运行的所有客户端都应该使用

LISTENER_INTERNAL://kafka-host:29092

Docker网络以外的所有客户端都应使用

LISTENER_EXTERNAL://kafka-host:9092