到/etc/kafka/server.properties,使用以下命令配置代理:
############################# Server Basics #############################
# The id of the broker. This must be set to a unique integer for each broker.
broker.id=0
############################# Socket Server Settings #############################
# The address the socket server listens on. It will get the value returned from
# java.net.InetAddress.getCanonicalHostName() if not configured.
# FORMAT:
# listeners = listener_name://host_name:port
# EXAMPLE:
# listeners = PLAINTEXT://your.host.name:9092
listeners=PLAINTEXT://<MY_HOST_NAME>:9092,SASL_SSL://<MY_HOST_NAME>:9093
要查看我经营的经纪人:
/opt/confluent-kafka/v5.5.0/bin/zookeeper-shell localhost:2181 ls /brokers/ids
返回:
Connecting to localhost:2181
WATCHER::
WatchedEvent state:SyncConnected type:None path:null
[]
所以,看来券商并没有跑。因为kafka server.properties(上面)包含:
listeners=PLAINTEXT://<MY_HOST_NAME>:9092,SASL_SSL://<MY_HOST_NAME>:9093
经纪人不应该在吗?
我的理解是 listeners=PLAINTEXT://<MY_HOST_NAME>:9092,SASL_SSL://<MY_HOST_NAME>:9093
是允许代理访问的配置吗?
1条答案
按热度按时间c9qzyr3d1#
我假设连接在同一主机内(这里不涉及播发侦听器或外部客户机)。更改listeners属性以使代理侦听所有接口:
listeners=PLAINTEXT://0.0.0.0:9092,SASL_SSL://0.0.0.0:9093
如果你把你的<hostname>
作为听众,localhost
不会被识别为有效的绑定点:没有注册的“localhost
“侦听器,只是在配置中指定的一个,<hostname>
.通过设置
0.0.0.0
作为监听器,代理将绑定到所有接口,因此接受localhost
作为有效的终结点。你可以在这里找到更多关于这个的信息。