验证期间终止节点的连接 - kafka

1 回答

• 0

  这是一个非常普遍的错误 . 如果我们启用调试日志，这将有助于解决身份验证问题的原因 . 转到kafka的config目录中的log4j.properties文件，并将日志设置为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
  

  回复于 2024-04-29T13:32:51+08:00