environment CentOS Linux release 7.5.1804 (Core) java version "1.8.0_191"
canal 1.1.3 mysql 5.7.24
日志输出错误内容:
2019-01-17 11:49:28.205 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 1 : {example=LEADER_NOT_AVAILABLE} 2019-01-17 11:49:28.205 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 1 : {example=LEADER_NOT_AVAILABLE} 2019-01-17 11:49:28.343 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 3 : {example=LEADER_NOT_AVAILABLE} 2019-01-17 11:49:28.343 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 3 : {example=LEADER_NOT_AVAILABLE} 2019-01-17 11:49:28.462 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 4 : {example=LEADER_NOT_AVAILABLE} 2019-01-17 11:49:28.462 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error while fetching metadata with correlation id 4 : {example=LEADER_NOT_AVAILABLE}
原提问者GitHub用户GitGitGitWang
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
根据日志内容,看起来是Kafka的错误,而不是Canal的问题。可能是Kafka集群中的某个broker不可用,导致LEADER_NOT_AVAILABLE错误。建议您检查Kafka集群的状态,确保所有broker都在运行中,并且Kafka主题是否已正确创建。您可以运行以下命令来检查Kafka集群状态:
bin/kafka-topics.sh --describe --zookeeper <zookeeper_host>:<zookeeper_port> --topic <topic_name>
如果Kafka集群和主题都已正确配置,则建议您检查Canal的配置文件中的Kafka配置是否正确。