首先,缺少
security.inter.broker.protocol=SASL_PLAINTEXT
其次
listener.security.protocol.map=CONTROLLER:SASL_PLAINTEXT,PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL,CONTROLLER:PLAINTEXT
CONTROLLER你配置了2个,看日志用的最后的的策略PLAINTEXT
,而你并没有定义它。
你这个很多没有用,我给你精简了一下
listener.security.protocol.map=CONTROLLER:PLAINTEXT,SASL_PLAINTEXT:SASL_PLAINTEXT