服务器部分报错信息截图
2022-06-11 17:18:18,140 (PollableSourceRunner-KafkaSource-r1) [WARN - org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:961)] [Consumer clientId=consumer-1, groupId=gmall] 1 partitions have leader brokers without a matching listener, including [topic_log-0]
2022-06-11 17:18:18,241 (PollableSourceRunner-KafkaSource-r1) [WARN - org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:961)] [Consumer clientId=consumer-1, groupId=gmall] 1 partitions have leader brokers without a matching listener, including [topic_log-0]
2022-06-11 17:18:18,342 (PollableSourceRunner-KafkaSource-r1) [WARN - org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:961)] [Consumer clientId=consumer-1, groupId=gmall] 1 partitions have leader brokers without a matching listener, including [topic_log-0]
2022-06-11 17:18:18,444 (PollableSourceRunner-KafkaSource-r1) [WARN - org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:961)] [Consumer clientId=consumer-1, groupId=gmall] 1 partitions have leader brokers without a matching listener, including [topic_log-0]
2022-06-11 17:18:18,545 (PollableSourceRunner-KafkaSource-r1) [WARN - org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:961)] [Consumer clientId=consumer-1, groupId=gmall] 1 partitions have leader brokers without a matching listener, including [topic_log-0]
2022-06-11 17:18:18,647 (PollableSourceRunner-KafkaSource-r1) [WARN - org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:961)] [Consumer clientId=consumer-1, groupId=gmall] 1 partitions have leader brokers without a matching listener, including [topic_log-0]
2022-06-11 17:18:18,749 (PollableSourceRunner-KafkaSource-r1) [WARN - org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:961)] [Consumer clientId=consumer-1, groupId=gmall] 1 partitions have leader brokers without a matching listener, including [topic_log-0]
2022-06-11 17:18:18,851 (PollableSourceRunner-KafkaSource-r1) [WARN - org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:961)] [Consumer clientId=consumer-1, groupId=gmall] 1 partitions have leader brokers without a matching listener, including [topic_log-0]
2022-06-11 17:18:18,954 (PollableSourceRunner-KafkaSource-r1) [WARN - org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:961)] [Consumer clientId=consumer-1, groupId=gmall] 1 partitions have leader brokers without a matching listener, including [topic_log-0]
2022-06-11 17:18:19,055 (PollableSourceRunner-KafkaSource-r1) [WARN - org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.handleCompletedMetadataResponse(NetworkClient.java:961)] [Consumer clientId=consumer-1, groupId=gmall] 1 partitions have leader brokers without a matching listener, including [topic_log-0]
报错原因:可能kafka服务集群中某个节点宕机了。
解决方法:重新启动kafka集群尝试一下。
精彩文章
发表评论