我想把9093暴露在码头集装箱外面。当我将kafka-0端口设置为9093并且kafka\u播发\u侦听器如下时,我无法连接到localhost:9093 as 显示在下面的docker compose文件中。
version: '3'
services:
kafka-0:
image: confluentinc/cp-kafka:5.2.1
container_name: kafka-0
hostname: kafka-0
ports:
- "9093:9092"
environment:
- KAFKA_BROKER_ID=1
- KAFKA_ZOOKEEPER_CONNECT=wise-nlp-zookeeper:2181
- KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
- KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka-0:29094,PLAINTEXT_HOST://localhost:9093
- KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
depends_on:
- zookeeper
zookeeper:
image: confluentinc/cp-zookeeper:5.3.1
container_name: zookeeper
ports:
- "2182:2181"
environment:
- ZOOKEEPER_CLIENT_PORT=2181
但是,当我换成
ports:
- "9092:9092"
和
- KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka-0:29094,PLAINTEXT_HOST://localhost:9092
我可以联系到Kafka经纪人localhost:9092.
如何将外部端口更改为9093以便应用程序连接?我想建立多个经纪人。
1条答案
按热度按时间c0vxltue1#
为什么现在不行?
播发侦听器(如中所定义)
KAFKA_ADVERTISED_LISTENERS
)是代理在其初始连接中返回给客户机以便在后续连接中使用的主机和端口。如果您希望外部客户机使用9093
KAFKA_ADVERTISED_LISTENERS=…PLAINTEXT_HOST://localhost:9093
是正确的。但是,您尚未配置KAFKA_LISTENERS
,如果您在代理日志启动时检查它,它将默认为KAFKA_ADVERTISED_LISTENERS
:因此,在此状态下,代理正在侦听端口9093,但使用此docker compose指令,您已将外部连接重定向到容器内的9093到9092上的容器中:
因此,您的外部连接将转到容器中的端口9092,而代理没有监听此端口。你可以用
nc
:❌ 您将看到客户端连接失败
你怎么能修好它?
您可以:
使用docker端口重定向将侦听器更改为位于目标端口上。这将工作,但我个人认为是更混乱。
更改docker端口重定向以侦听器所在的端口为目标。这是我将使用的选项,因为它更清晰(例如端口
9093
在整个过程中使用,而不是混合9092
以及9093
(一起)选项1:将侦听器更改为位于docker端口重定向的目标端口上
✅测试:
选项2:更改docker端口重定向以侦听器所在的端口为目标
✅测试
从docker网络连接到kafka
上面的例子是关于从docker主机连接到kafka的。如果要从docker网络(例如另一个容器)内连接到它,则需要使用
kafka-0:29094
作为代理主机和ip。如果你想用localhost:9093
然后客户端容器将解析localhost
它自己的容器,因此失败。多个经纪人
请参阅这里的示例docker compose与多个kafka代理。
参考文献
https://rmoff.net/2018/08/02/kafka-listeners-explained/