使用kafka-console-consumer.sh不停報WARN如何解決

本篇內容介紹了“使用kafka-console-consumer.sh不停報WARN如何解決”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

kafka-console-consumer.sh不停報WARN的解決

首先確認你的服務器你所需要的所有端口都打開了!

./kafka-console-consumer.sh --bootstrap-server 宿主機IP:9092 --topic 主題名 --from-beginning

端口都打開的情況使用以上命令還繼續各種報WARN請檢查kafka相關配置

listeners=PLAINTEXT://*********:9092

以上*處配置IP應為宿主機IP地址一致

./kafka-console-consumer.sh --bootstrap-server *********:9092 --topic 主題名 --from-beginning

問題得到解決

我是這個原因，可以從報錯信息中得知解析地址中的broker失敗了修改為宿主機IP得到解決

WARN [Consumer clientId=consumer-console-consumer-21595-1, groupId=console-consumer-21595] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

使用Kafka的kafka-console-consumer.sh不能消費消息

使用Ambari搭建的kafka集群，在使用kafka-console-producer.sh的時候，指定--broker-list的值需要從server.properties中查看listeners=PLAINTEXT://的值。

同理，使用kafka-console-consumer.sh的時候，指定--bootstrap-server也需要從server.properties中查看listeners=PLAINTEXT://的值。

所以，以上已經是確保了配置沒有問題的情況下，出現了kafka使用kafka-console-consumer.sh沒有消費消息。

問題

使用kafka-console-consumer.sh沒有消費消息

解決

（1）在無意中查看了kafka的server.log日志，發現一直在報如下錯誤

ERROR [KafkaApi-1001] Number of alive brokers '2' does not meet the required replication factor '3' for the offsets topic (configured via 'offsets.topic.replication.factor'). This error can be ignored if the cluster is starting up and not all brokers are up yet. (kafka.server.KafkaApis)

（2）分析了下局面意思，大概就是broker的數量為2，但是server.properties配置的offsets.topic.replication.factor的值為3。

看到這里我大概有兩個解決方案

一、添加broker的數目

二、修改server.properties中offsets.topic.replication.factor的值，改成2【Ambari中該值在kafka-broker中修改】

“使用kafka-console-consumer.sh不停報WARN如何解決”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！