使用kafka-console-consumer.sh不停報(bào)WARN的問(wèn)題及解決
kafka-console-consumer.sh不停報(bào)WARN的解決
首先確認(rèn)你的服務(wù)器你所需要的所有端口都打開了!
./kafka-console-consumer.sh --bootstrap-server 宿主機(jī)IP:9092 --topic 主題名 --from-beginning
端口都打開的情況使用以上命令還繼續(xù)各種報(bào)WARN請(qǐng)檢查kafka相關(guān)配置
listeners=PLAINTEXT://*********:9092
以上*處配置IP應(yīng)為宿主機(jī)IP地址一致
./kafka-console-consumer.sh --bootstrap-server *********:9092 --topic 主題名 --from-beginning
問(wèn)題得到解決
我是這個(gè)原因，可以從報(bào)錯(cuò)信息中得知解析地址中的broker失敗了修改為宿主機(jī)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不能消費(fèi)消息
使用Ambari搭建的kafka集群，在使用kafka-console-producer.sh的時(shí)候，指定--broker-list的值需要從server.properties中查看listeners=PLAINTEXT://的值。
同理，使用kafka-console-consumer.sh的時(shí)候，指定--bootstrap-server也需要從server.properties中查看listeners=PLAINTEXT://的值。
所以，以上已經(jīng)是確保了配置沒(méi)有問(wèn)題的情況下，出現(xiàn)了kafka使用kafka-console-consumer.sh沒(méi)有消費(fèi)消息。
問(wèn)題
使用kafka-console-consumer.sh沒(méi)有消費(fèi)消息
解決
（1）在無(wú)意中查看了kafka的server.log日志，發(fā)現(xiàn)一直在報(bào)如下錯(cuò)誤
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的數(shù)量為2，但是server.properties配置的offsets.topic.replication.factor的值為3。
看到這里我大概有兩個(gè)解決方案
一、添加broker的數(shù)目
二、修改server.properties中offsets.topic.replication.factor的值，改成2【Ambari中該值在kafka-broker中修改】
總結(jié)
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
JAVA幫助文檔全系列 JDK1.5 JDK1.6 JDK1.7 官方中英完整版整理
JDK(Java Development Kit，Java開發(fā)包，Java開發(fā)工具)是一個(gè)寫Java的applet和應(yīng)用程序的程序開發(fā)環(huán)境。它由一個(gè)處于操作系統(tǒng)層之上的運(yùn)行環(huán)境還有開發(fā)者編譯，調(diào)試和運(yùn)行用Java語(yǔ)言寫的applet和應(yīng)用程序所需的工具組成2014-01-01
這篇文章主要介紹了Mybatis中的延遲加載詳細(xì)解讀,Mybatis中延遲加載又稱為懶加載,是指在進(jìn)行關(guān)聯(lián)查詢時(shí),按照設(shè)置延遲規(guī)則推遲對(duì)關(guān)聯(lián)對(duì)象的select查詢,延遲加載可以有效的減少數(shù)據(jù)庫(kù)的壓力,需要的朋友可以參考下2023-10-10
SpringBoot ThreadLocal實(shí)現(xiàn)公共字段自動(dòng)填充案例講解
每一次在Controller層中封裝改動(dòng)數(shù)據(jù)的方法時(shí)都要重新設(shè)置一些共性字段，顯得十分冗余。為了解決此問(wèn)題也是在項(xiàng)目中第一次利用到線程，總的來(lái)說(shuō)還是讓我眼前一亮，也開闊了視野，對(duì)以后的開發(fā)具有深遠(yuǎn)的意義2022-10-10
Java語(yǔ)言實(shí)現(xiàn)非遞歸實(shí)現(xiàn)樹的前中后序遍歷總結(jié)
今天小編就為大家分享一篇關(guān)于Java語(yǔ)言實(shí)現(xiàn)非遞歸實(shí)現(xiàn)樹的前中后序遍歷總結(jié)，小編覺(jué)得內(nèi)容挺不錯(cuò)的，現(xiàn)在分享給大家，具有很好的參考價(jià)值，需要的朋友一起跟隨小編來(lái)看看吧2019-01-01
Java并發(fā)編程之關(guān)鍵字volatile的深入解析
提高java的并發(fā)編程,就不得不提volatile關(guān)鍵字,不管是在面試還是實(shí)際開發(fā)中volatile都是一個(gè)應(yīng)該掌握的技能,這篇文章主要給大家介紹了關(guān)于Java并發(fā)編程之關(guān)鍵字volatile的相關(guān)資料,需要的朋友可以參考下2021-09-09
SpringBoot中使用?ThreadLocal?進(jìn)行多線程上下文管理及注意事項(xiàng)小結(jié)
本文詳細(xì)介紹了ThreadLocal的原理、使用場(chǎng)景和示例代碼,并在SpringBoot中使用ThreadLocal保存請(qǐng)求中攜帶的用戶信息,ThreadLocal通過(guò)為每個(gè)線程維護(hù)獨(dú)立的變量副本,解決了線程安全問(wèn)題,感興趣的朋友一起看看吧2025-02-02
SpringBoot搭建多數(shù)據(jù)源的實(shí)現(xiàn)方法
說(shuō)起多數(shù)據(jù)源,一般都來(lái)解決那些問(wèn)題呢,主從模式或者業(yè)務(wù)比較復(fù)雜需要連接不同的分庫(kù)來(lái)支持業(yè)務(wù)。本文主要介紹了SpringBoot搭建多數(shù)據(jù)源的實(shí)現(xiàn)方法，感興趣的可以了解一下，感興趣的可以額了解一下2021-12-12
java多線程開發(fā)ScheduledExecutorService簡(jiǎn)化方式
這篇文章主要為大家介紹了java多線程開發(fā)ScheduledExecutorService的簡(jiǎn)化方式，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步2022-03-03
這篇文章主要介紹了IDEA如何設(shè)置忽略git提交的文件問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-11-11
詳解SpringBoot下文件上傳與下載的實(shí)現(xiàn)
這篇文章主要介紹了SpringBoot下文件上傳與下載的實(shí)現(xiàn)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-05-05