我有两个Kafka的听众
listeners=PUBLIC_SASL://0.0.0.0:5011,PUBLIC_PLAIN://0.0.0.0:5010
advertised.listeners=PUBLIC_SASL://192.168.181.2:5011,PUBLIC_PLAIN://192.168.181.2:5010
listener.security.protocol.map=PUBLIC_SASL:SASL_PLAINTEXT,PUBLIC_PLAIN:PLAINTEXT
inter.broker.listener.name=PUBLIC_SASL
5010
是纯文本,5011
是sasl_纯文本.
启动后,我在zookeeper(/brokers/ids/$id)中找到了以下信息:
{
"listener_security_protocol_map": {
"PUBLIC_SASL": "SASL_PLAINTEXT",
"PUBLIC_PLAIN": "PLAINTEXT"
},
"endpoints": [
"PUBLIC_SASL://192.168.181.2:5011",
"PUBLIC_PLAIN://192.168.181.2:5010"
],
"jmx_port": -1,
"features": { },
"host": "192.168.181.2",
"timestamp": "1658485899402",
"port": 5010,
"version": 5
}
port
字段是什么意思?为什么端口是5010
?我可以把它改为5011
吗?
1条答案
按热度按时间llycmphe1#
您看到的是
advertised.port
和advertised.host
Kafka设置,为了向后兼容,可以从advertised.listener
列表中解析这些设置,但是这两个设置都已过时,Kafka协议现在使用协议Map和相应的endpoints
列表。