соединение с узлом прервано во время аутентификации - kafka

Question

соединение с узлом прекращено во время аутентификации. Это может указывать на то, что аутентификация не удалась из-за неверных учетных данных. (Org.apache.kafka.clients.NetworkClient

Answer 1

это очень общая ошибка. если мы включим журналы отладки, это поможет понять, почему возникают проблемы с аутентификацией. Перейдите к файлу log4j.properties в вашем каталоге конфигурации kafka и установите для журналов DEBUG вместо INFO.

Как показано ниже, измените INFO на DEBUG. это помогло бы выяснить, в чем именно заключается проблема с ошибками соединений SSL.

Как выдача сертификата или неподписанный сертификат тогда это облегчает решение и дальнейшую отладку.

log4j.rootLogger=INFO, kafkaAppender

log4j.appender.controllerAppender=org.apache.log4j.DailyRollingFileAppender
log4j.appender.controllerAppender.DatePattern=.yyyy-MM-dd
log4j.appender.controllerAppender.File=/var/log/kafka/kafka-controller.log
log4j.appender.controllerAppender.layout=org.apache.log4j.PatternLayout
log4j.appender.controllerAppender.layout.ConversionPattern=[%d] %p %m (%c)%n

log4j.appender.kafkaAppender=org.apache.log4j.DailyRollingFileAppender
log4j.appender.kafkaAppender.DatePattern=.yyyy-MM-dd
log4j.appender.kafkaAppender.File=/var/log/kafka/kafka.log
log4j.appender.kafkaAppender.layout=org.apache.log4j.PatternLayout
log4j.appender.kafkaAppender.layout.ConversionPattern=[%d] %p %m (%c)%n

log4j.appender.requestAppender=org.apache.log4j.DailyRollingFileAppender
log4j.appender.requestAppender.DatePattern=.yyyy-MM-dd
log4j.appender.requestAppender.File=/var/log/kafka/kafka-request.log
log4j.appender.requestAppender.layout=org.apache.log4j.PatternLayout
log4j.appender.requestAppender.layout.ConversionPattern=[%d] %p %m (%c)%n

log4j.appender.stateChangeAppender=org.apache.log4j.DailyRollingFileAppender
log4j.appender.stateChangeAppender.DatePattern=.yyyy-MM-dd
log4j.appender.stateChangeAppender.File=/var/log/kafka/kafka-state-change.log
log4j.appender.stateChangeAppender.layout=org.apache.log4j.PatternLayout
log4j.appender.stateChangeAppender.layout.ConversionPattern=[%d] %p %m (%c)%n

log4j.logger.kafka.controller=INFO, controllerAppender
log4j.additivity.kafka.controller=false

log4j.logger.kafka.network.RequestChannel$=WARN, requestAppender
log4j.additivity.kafka.network.RequestChannel$=false

log4j.logger.kafka.request.logger=WARN, requestAppender
log4j.additivity.kafka.request.logger=false

log4j.logger.org.IOItec.zkclient.ZkClient=INFO

log4j.logger.state.change.logger=INFO, stateChangeAppender
log4j.additivity.state.change.logger=false