0 声望

这家伙太懒,什么都没留下

个人动态
  • 回复 不会游泳的鱼关于KAFKA10.0.1使用SASL_PLAINTEXT遇到的问题 中 :

    大神

    [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

    3年前