11:57:24 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN o.apache.kafka....

錯誤以下：

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，發現日誌刷新錯誤變了，發現須要重啓服務，而後從新啓動後日志恢復正常