国产无码综合区,色欲AV无码国产永久播放,无码天堂亚洲国产AV,国产日韩欧美女同一区二区

Kafka Group coordinator xxx:9092 (id: xxx rack: null) is unavailable or invalid

2年前作者：DanielMaster分類：Toy博客閱讀(21)違法舉報(bào)

這篇具有很好參考價(jià)值的文章主要介紹了Kafka Group coordinator xxx:9092 (id: xxx rack: null) is unavailable or invalid。希望對(duì)大家有所幫助。如果存在錯(cuò)誤或未考慮完全的地方，請(qǐng)大家不吝賜教，您也可以點(diǎn)擊"舉報(bào)違法"按鈕提交疑問(wèn)。

問(wèn)題描述：

Kafka本身啟動(dòng)和相互通信沒有問(wèn)題，但是在使用Java API 模擬消費(fèi)者連接到Kafka的時(shí)候出現(xiàn)報(bào)錯(cuò)
discovered group coordinator,Kafka,kafka

2022-03-03 09:31:22[Consumer clientId=consumer-1, groupId=test-consumer-group] Discovered group xxx:9092 (id: xxx rack: null)
2022-03-03 09:31:34[Consumer clientId=consumer-1, groupId=test-consumer-group] Group coordinator xxxt:9092 (id: xxx rack: null) is unavailable or invalid, will attempt rediscovery

原因分析：

我們可以注意一下控制臺(tái)給出的域名地址，這個(gè)域名可能是因?yàn)榻馕鰡?wèn)題或者限于遠(yuǎn)程服務(wù)器的安全策略做了轉(zhuǎn)換

驗(yàn)證這個(gè)問(wèn)題的辦法，在windows開啟telnet命令，在cmd中

telnet xxx 9092

發(fā)現(xiàn)是無(wú)法連接的

解決方案：

使用管理員權(quán)限手動(dòng)在C:\Windows\System32\drivers\etc\hosts文件中添加映射，手動(dòng)讓自己的電腦認(rèn)識(shí)這個(gè)IP

格式：

kafka服務(wù)器的ip和kafka服務(wù)器對(duì)應(yīng)的域名

example:

# localhost name resolution is handled within DNS itself.
#	127.0.0.1       localhost
#	::1             localhost
192.168.98.101 hadoop01

在此連接到kafka，成功連接
discovered group coordinator,Kafka,kafka 文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-573075.html

到了這里，關(guān)于Kafka Group coordinator xxx:9092 (id: xxx rack: null) is unavailable or invalid的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！

本文來(lái)自互聯(lián)網(wǎng)用戶投稿，該文觀點(diǎn)僅代表作者本人，不代表本站立場(chǎng)。本站僅提供信息存儲(chǔ)空間服務(wù)，不擁有所有權(quán)，不承擔(dān)相關(guān)法律責(zé)任。如若轉(zhuǎn)載，請(qǐng)注明出處：如若內(nèi)容造成侵權(quán)/違法違規(guī)/事實(shí)不符，請(qǐng)點(diǎn)擊違法舉報(bào)進(jìn)行投訴反饋，一經(jīng)查實(shí)，立即刪除！

分享到：

領(lǐng)支付寶紅包贊助服務(wù)器費(fèi)用

kafka發(fā)送數(shù)據(jù)報(bào)錯(cuò)： Error connecting to node xxxxx:9092 (id: 1 rack: null)java.net.UnknownHostExceptio
報(bào)錯(cuò)內(nèi)容： warn報(bào)錯(cuò)： ?[kafka-producer-network-thread | producer-1] WARN ?org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error connecting to node xxxxx:9092 (id: 1 rack: null) java.net.UnknownHostException: xxxxx ?? ?at java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797) ?? ?at java.base/java.net.
2024年02月08日
瀏覽(25)
命令消費(fèi)kafka報(bào)錯(cuò)(id: -1 rack: null) disconnected
CDP 717環(huán)境使用 kafka-console-consumer 命令消費(fèi)kafka報(bào)錯(cuò)如下是因?yàn)閗afka開啟了kerberos 具體檢查可見 1、In Cloudera Manager, navigate to Kafka Configuration . 2、Set SSL Client Authentication to none . 3、Set Inter Broker Protocol to SASL_PLAINTEXT . 1、創(chuàng)建文件 jaas.conf 注意：這里 principal 不清楚的話可以先執(zhí)行
2024年02月05日
瀏覽(17)
[kafka] 消費(fèi)沒有數(shù)據(jù)的問(wèn)題解決Group coordinator lookup failed: The coordinator is not available
[kafka] 消費(fèi)沒有數(shù)據(jù)的問(wèn)題解決Group coordinator lookup failed: The coordinator is not available 目錄前言一、解決問(wèn)題在項(xiàng)目中使用了kafka，生產(chǎn)者可以正常的往里放數(shù)據(jù)，但是消費(fèi)者無(wú)法獲取數(shù)據(jù)，通過(guò)kafka命令獲取也無(wú)法獲取，觀察控制臺(tái)發(fā)現(xiàn)，報(bào)了如下錯(cuò)誤。排查發(fā)現(xiàn)topic中沒有
2024年02月07日
瀏覽(17)
kafka-報(bào)錯(cuò)-The coordinator is not aware of this member
我在項(xiàng)目里把原來(lái)用著的獨(dú)立消費(fèi)者 consumer-group-id 同時(shí)當(dāng)做消費(fèi)者組來(lái)消費(fèi)分區(qū)信息，導(dǎo)致協(xié)調(diào)器找不到這個(gè) consumer-group-id 注冊(cè)兩個(gè)測(cè)試 topic 寫一個(gè)消費(fèi)者組啟動(dòng)項(xiàng)目，發(fā)送消息報(bào)錯(cuò)日志查看kafka服務(wù)器的消費(fèi)者狀態(tài)
2024年02月13日
瀏覽(19)
kafka消費(fèi)者的group id從哪里獲取
今天跑了一下kafka的示例demo，突然意識(shí)到一個(gè)問(wèn)題。消費(fèi)者拉取broker的消息時(shí)需要指定group id，而生產(chǎn)者將消息發(fā)送到broker的時(shí)候并不會(huì)指定group id，那么消費(fèi)者的group id從哪里獲取呢？查閱我的這篇文章?kafka消費(fèi)者?的3.1小節(jié)，如果不配置該參數(shù)，則會(huì)拋出異常。為此，筆
2024年02月11日
瀏覽(16)
Kafka中的group_id：實(shí)現(xiàn)消息分組消費(fèi)的關(guān)鍵
Kafka是一種高性能、可擴(kuò)展的分布式消息系統(tǒng)，被廣泛應(yīng)用于大規(guī)模數(shù)據(jù)流處理的場(chǎng)景。在Kafka中，group_id是一個(gè)關(guān)鍵概念，用于實(shí)現(xiàn)消息的分組消費(fèi)。本文將詳細(xì)介紹group_id的作用和使用方法，并提供相應(yīng)的源代碼示例。 Kafka消息分組消費(fèi)的概念是指多個(gè)消費(fèi)者協(xié)同消費(fèi)同一
2024年02月03日
瀏覽(13)
kafka報(bào)錯(cuò):No group.id found in consumer config, container properties
Caused by: java.lang.IllegalStateException: No group.id found in consumer config, container properties, or @KafkaListener annotation; a group.id is required when group management is used. 報(bào)錯(cuò)提示沒有配置groupid,那么配置groupid即可配置group-id，重啟服務(wù)器即可
2024年02月11日
瀏覽(26)
解決There is no PasswordEncoder mapped for the id “null“問(wèn)題
springsecurity從4.2升級(jí)到5.0之后，做簡(jiǎn)單的登錄，出現(xiàn)如下所示的錯(cuò)誤：根據(jù)官方文檔的資料和網(wǎng)上解決辦法，需要做一些修改。默認(rèn)情況下與4.2版本不同的是，springsecurity5.0密碼加密方式采用了bcrypt的方式，而且密碼直接配置在xml文件中，不光是需要使用BCryptPasswordEncoder來(lái)加
2023年04月09日
瀏覽(83)
關(guān)于Spring中java.lang.NullPointerException: Cannot invoke “xxx“ because “xxx“ is null 的問(wèn)題
當(dāng)我好不容易編譯成功，開始運(yùn)行時(shí)，使用postman測(cè)試接口功能時(shí)卻返回了一個(gè)錯(cuò)誤：編譯成功開始運(yùn)行： postman返回：并在IDEA顯示了 java.lang.NullPointerException: Cannot invoke “com.example.mybatisdemo.mapper.StudentMapper.ListStudent()” because “this.studentMapper” is null 錯(cuò)誤指向了Service層調(diào)用的
2024年02月05日
瀏覽(21)
為什么kafka 需要 subscribe 的 group.id？我們是否需要使用 commitSync 手動(dòng)提交偏移量？
消費(fèi)概念： Kafka 使用消費(fèi)者組的概念來(lái)實(shí)現(xiàn)主題的并行消費(fèi) - 每條消息都將在每個(gè)消費(fèi)者組中傳遞一次，無(wú)論該組中實(shí)際有多少個(gè)消費(fèi)者。所以 group 參數(shù)是強(qiáng)制性的，如果沒有組，Kafka 將不知道如何對(duì)待訂閱同一主題的其他消費(fèi)者。偏移量：每當(dāng)我們啟動(dòng)一個(gè)消費(fèi)者時(shí)，
2024年02月12日
瀏覽(27)