11:57:24 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=jiatian_api] 3 partitions have leader……


錯誤如下:

11:57:24 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN  o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=test_api] 3 partitions have leader brokers without a matching listener, including [test_topic_order-0, test_topic_goods-0, test_topic_refund-0]

11:57:24 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN  o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=test_api] 3 partitions have leader brokers without a matching listener, including [test_topic_order-0, test_topic_goods-0, test_topic_refund-0]

11:57:25 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN  o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=test_api] 3 partitions have leader brokers without a matching listener, including [test_topic_order-0, test_topic_goods-0, test_topic_refund-0]

 

用tail命令查看會發現日志在不停的刷上面內容,開始排查問題,最后定位在配置文件server.properties里面,通過網上一些文章,嘗試了一下

第一個:

把192.168.2.9改成localhost

試了之后,依然報錯:

11:57:00 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN  o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=test_api] Connection to node 0 could not be established. Broker may not be available.

11:57:01 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN  o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=test_api] Connection to node 0 could not be established. Broker may not be available.

11:57:02 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN  o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=test_api] Connection to node 0 could not be established. Broker may not be available.

11:57:04 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN  o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=test_api] Connection to node 0 could not be established. Broker may not be available.

11:57:05 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN  o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=test_api] Connection to node 0 could not be established. Broker may not be available.

會發現報錯改變了,看來這么改不對,回頭想了下,首先排除ip和端口問題,然后想到會不會是參數哪里有問題,於是

參數

默認值

描述

broker.id

-1

每一個boker都有一個唯一的id作為它們的名字。當該服務器的IP地址發生改變時,broker.id沒有變化,則不會影響consumers的消息情況

num.network.threads

3

broker處理消息的最大線程數,一般情況下數量為cpu核數

num.io.threads

8

處理IO的線程數

num.partitions

1

默認分區數

 

發現參數也沒什么問題,接着往下看配置文件,看了下zookeeper連接,通過ps和netstat命令查到本機上有一個單台和一個由三台組成的zookeeper集群

 

更改了一下zookeeper,發現日志刷新錯誤變了,發現需要重啟服務,然后重新啟動后日志恢復正常


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM