[kafka] 消費沒有數(shù)據(jù)的問題解決Group coordinator lookup failed: The coordinator is not available

目錄

前言

一、解決問題

前言

在項目中使用了kafka，生產(chǎn)者可以正常的往里放數(shù)據(jù)，但是消費者無法獲取數(shù)據(jù)，通過kafka命令獲取也無法獲取，觀察控制臺發(fā)現(xiàn)，報了如下錯誤。

DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 133 to Cluster(id = YFJdX6kITzuEPD3F4zdZEw, nodes = [master:9092 (id: 39 rack: null)], partitions = [Partition(topic = fuxi_test, partition = 0, leader = 39, replicas = [39], isr = [39], offlineReplicas = [])], controller = master:9092 (id: 39 rack: null))
[ForkJoinPool-1-worker-5] DEBUG o.a.k.c.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=test_consumer] Sending FindCoordinator request to broker master:9092 (id: 39 rack: null)
[ForkJoinPool-1-worker-5] DEBUG o.a.k.c.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=test_consumer] Received FindCoordinator response ClientResponse(receivedTimeMs=1590026706655, latencyMs=4, disconnected=false, requestHeader=RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=2, clientId=consumer-1, correlationId=265), responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=COORDINATOR_NOT_AVAILABLE, node=:-1 (id: -1 rack: null)))
[ForkJoinPool-1-worker-5] DEBUG o.a.k.c.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=test_consumer] Group coordinator lookup failed: The coordinator is not available.
[ForkJoinPool-1-worker-5] DEBUG o.a.k.c.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=test_consumer] Coordinator discovery failed, refreshing metadata

一、解決問題

排查發(fā)現(xiàn)topic中沒有__consumer_offsets，必須有他才可以正常獲取到值，創(chuàng)建命令如下，創(chuàng)建后重啟kafka服務和zookeeper服務，就可以正常獲取到數(shù)據(jù)了。

kafka-topics --zookeeper 127.0.0.1:2181 --partitions 1 --replication-factor 1 --create --topic __consumer_offsets

kafka-topics.bat在kafka/bin/windows下

?一定記得執(zhí)行命令后重啟kafka服務。

到此問題解決。希望對小伙伴們有幫助。文章來源地址http://www.zghlxwxcb.cn/news/detail-733743.html

到了這里，關于[kafka] 消費沒有數(shù)據(jù)的問題解決Group coordinator lookup failed: The coordinator is not available的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章，希望大家以后多多支持TOY模板網(wǎng)！