java.lang.IllegalArgumentException при добавлении аутентификации SASL_PLAINTEXT в брокер kafka - PullRequest
Новая
       18

java.lang.IllegalArgumentException при добавлении аутентификации SASL_PLAINTEXT в брокер kafka

0 голосов
/ 07 мая 2019

Я пытаюсь настроить аутентификацию SASL_PLAINTEXT для брокера kafka, ниже моя конфигурация. 

advertised.listeners=SASL_PLAINTEXT://127.0.0.1:9092
listeners=SASL_PLAINTEXT://127.0.0.1:9092

security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
sasl.jaas.config=/var/lib/kafka/config/kafka_jaas.conf

После запуска zookeeper и kafka я получаю исключение ниже

java.lang.IllegalArgumentException: требование не выполнено: inter.broker.listener.name должно быть именем слушателя, определенным в advertised.listeners.Допустимые параметры, основанные на настроенных в настоящий момент прослушивателях: PLAINTEXT java.lang.IllegalArgumentException: требование не выполнено: inter.broker.listener.name должно быть именем прослушивателя, определенным в advertised.listeners.Допустимые параметры, основанные на текущих настроенных слушателях: PLAINTEXT на scala.Predef $ .require (Predef.scala: 233) на kafka.server.KafkaConfig.validateValues ​​(KafkaConfig.scala: 1089) на kafka.server.KafkaConfig.: 1065) по адресу kafka.server.KafkaConfig $ .fromProps (KafkaConfig.scala: 795) по адресу kafka.server.KafkaConfig $ .fromProps (KafkaConfig.scala: 792) по адресу kafka.server.KafkaServerStartable $ .fromscertable $ 28ff.) на kafka.Kafka $ .main (Kafka.scala: 58) на kafka.Kafka.main (Kafka.scala)

...