欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

使用kafka-console-consumer.sh不停報WARN的問題及解決

 更新時間:2023年03月07日 09:42:46   作者:深沈  
這篇文章主要介紹了使用kafka-console-consumer.sh不停報WARN的問題及解決方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教

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

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

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

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

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

以上*處配置IP應(yīng)為宿主機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://的值。

所以,以上已經(jīng)是確保了配置沒有問題的情況下,出現(xiàn)了kafka使用kafka-console-consumer.sh沒有消費消息。

問題

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

解決

(1)在無意中查看了kafka的server.log日志,發(fā)現(xiàn)一直在報如下錯誤

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。

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

一、添加broker的數(shù)目

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

總結(jié)

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關(guān)文章

  • Jenkins如何實現(xiàn)自動打包部署linux

    Jenkins如何實現(xiàn)自動打包部署linux

    這篇文章主要介紹了Jenkins如何實現(xiàn)自動打包部署linux,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2020-11-11
  • Java實現(xiàn)數(shù)組轉(zhuǎn)字符串及字符串轉(zhuǎn)數(shù)組的方法分析

    Java實現(xiàn)數(shù)組轉(zhuǎn)字符串及字符串轉(zhuǎn)數(shù)組的方法分析

    這篇文章主要介紹了Java實現(xiàn)數(shù)組轉(zhuǎn)字符串及字符串轉(zhuǎn)數(shù)組的方法,結(jié)合實例形式分析了Java字符串及數(shù)組相關(guān)的分割、遍歷、追加等操作技巧,需要的朋友可以參考下
    2018-06-06
  • Java中的Excel框架使用詳解

    Java中的Excel框架使用詳解

    這篇文章主要介紹了Java中的Excel框架使用詳解,Java解析、生成Excel比較有名的框架有Apache poi、jxl,但他們都存在一個嚴重的問題就是非常的耗內(nèi)存,poi有一套SAX模式的API可以一定程度的解決一些內(nèi)存溢出的問題,需要的朋友可以參考下
    2023-11-11
  • 配置pom.xml用maven打包java工程的方法(推薦)

    配置pom.xml用maven打包java工程的方法(推薦)

    下面小編就為大家?guī)硪黄渲胮om.xml用maven打包java工程的方法(推薦)。小編覺得挺不錯的, 現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2016-06-06
  • Java詳解entity轉(zhuǎn)換到vo過程

    Java詳解entity轉(zhuǎn)換到vo過程

    這篇文章將用實例來和大家介紹一下entity轉(zhuǎn)換到vo的方法過程。文中的示例代碼講解詳細,對我們學(xué)習(xí)Java有一定的幫助,需要的可以參考一下
    2022-06-06
  • 淺談Java中的private方法是否可以被代理

    淺談Java中的private方法是否可以被代理

    這篇文章主要介紹了淺談Java中的private方法是否可以被代理,在?Java?8之前,接口可以有常量變量和抽象方法,我們不能在接口中提供方法實現(xiàn),如果我們要提供抽象方法和非抽象方法(方法與實現(xiàn))的組合,那么我們就得使用抽象類,需要的朋友可以參考下
    2023-12-12
  • spring boot中nativeQuery的用法

    spring boot中nativeQuery的用法

    這篇文章主要介紹了spring boot中nativeQuery的作用,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-07-07
  • Spring session實現(xiàn)共享單點登錄案例過程解析

    Spring session實現(xiàn)共享單點登錄案例過程解析

    這篇文章主要介紹了Spring session實現(xiàn)共享單點登錄案例過程解析,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2020-07-07
  • MybatisPlus 插入或更新數(shù)據(jù)時自動填充更新數(shù)據(jù)解決方案

    MybatisPlus 插入或更新數(shù)據(jù)時自動填充更新數(shù)據(jù)解決方案

    本文主要介紹了MybatisPlus 插入或更新數(shù)據(jù)時自動填充更新數(shù)據(jù)解決方案,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-09-09
  • springboot+mybaties項目中掃描不到@mapper注解的解決方法

    springboot+mybaties項目中掃描不到@mapper注解的解決方法

    本文主要介紹了springboot+mybaties項目中掃描不到@mapper注解的解決方法,該報錯表明掃描不到Mapper層,具有一定的參考價值,感興趣的可以了解一下
    2024-05-05

最新評論