不会游泳的鱼

WARN [Producer clientId=console-producer] Bootstrap broker 192.168.100.10:6667 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)

大佬们，请问我配置sasl之后，无论是消费还是生产数据都报这个错误

大神

[2021-09-01 18:23:51,480] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2021-09-01 18:23:51,937] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2021-09-01 18:23:51,987] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
java.lang.IllegalArgumentException: Error creating broker listeners from 'SASL_PLAINETXT://0.0.0.0:9092': No security protocol defined for listener SASL_PLAINETXT
        at kafka.utils.CoreUtils$.listenerListToEndPoints(CoreUtils.scala:268)
        at kafka.server.KafkaConfig.$anonfun$listeners$1(KafkaConfig.scala:1633)
        at kafka.server.KafkaConfig.listeners(KafkaConfig.scala:1632)
        at kafka.server.KafkaConfig.validateValues(KafkaConfig.scala:1732)
        at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1709)
        at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1273)
        at kafka.server.KafkaConfig$.fromProps(KafkaConfig.scala:1221)
        at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:34)
        at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:29)
        at kafka.Kafka$.main(Kafka.scala:68)
        at kafka.Kafka.main(Kafka.scala)
Caused by: java.lang.IllegalArgumentException: No security protocol defined for listener SASL_PLAINETXT
        at kafka.cluster.EndPoint$.$anonfun$createEndPoint$2(EndPoint.scala:48)
        at kafka.cluster.EndPoint$$$Lambda$38/1169794610.apply(Unknown Source)
        at scala.collection.immutable.Map$Map4.getOrElse(Map.scala:324)
        at kafka.cluster.EndPoint$.securityProtocol$1(EndPoint.scala:48)
        at kafka.cluster.EndPoint$.createEndPoint(EndPoint.scala:56)
        at kafka.utils.CoreUtils$.$anonfun$listenerListToEndPoints$6(CoreUtils.scala:265)
        at kafka.utils.CoreUtils$$$Lambda$37/815674463.apply(Unknown Source)
        at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:273)

报这个错是因为啥？他找不到SASL_PLAINTEXT

你好。最近我也开始用kerberos。请问，这个新的API是什么？望不吝赐教。

明白，非常感谢！

是的，安全相关的只支持新的消费者和生产者。