在Kafka zookeeper path/brokers/ids/$id中,'port'是什么意思

mfuanj7w  于 2022-12-09  发布在  Apache
关注(0)|答案(1)|浏览(155)

我有两个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吗?

llycmphe

llycmphe1#

您看到的是advertised.portadvertised.host Kafka设置,为了向后兼容,可以从advertised.listener列表中解析这些设置,但是这两个设置都已过时,Kafka协议现在使用协议Map和相应的endpoints列表。

相关问题