[kafka] 消费没有数据的问题解决Group coordinator lookup failed: The coordinator is not available

[kafka] 消费没有数据的问题解决Group coordinator lookup failed: The coordinator is not available目录前言一、解决问题前言在项目中使用了kafka生产者可以正常的往里放数据但是消费者无法获取数据通过kafka命令获取也无法获取观察控制台发现报了如下错误。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 clientIdconsumer-1, groupIdtest_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 clientIdconsumer-1, groupIdtest_consumer] Received FindCoordinator response ClientResponse(receivedTimeMs1590026706655, latencyMs4, disconnectedfalse, requestHeaderRequestHeader(apiKeyFIND_COORDINATOR, apiVersion2, clientIdconsumer-1, correlationId265), responseBodyFindCoordinatorResponse(throttleTimeMs0, errorMessagenull, errorCOORDINATOR_NOT_AVAILABLE, node:-1 (id: -1 rack: null))) [ForkJoinPool-1-worker-5] DEBUG o.a.k.c.consumer.internals.AbstractCoordinator - [Consumer clientIdconsumer-1, groupIdtest_consumer] Group coordinator lookup failed: The coordinator is not available. [ForkJoinPool-1-worker-5] DEBUG o.a.k.c.consumer.internals.AbstractCoordinator - [Consumer clientIdconsumer-1, groupIdtest_consumer] Coordinator discovery failed, refreshing metadata一、解决问题排查发现topic中没有__consumer_offsets必须有他才可以正常获取到值创建命令如下创建后重启kafka服务和zookeeper服务就可以正常获取到数据了。kafka-topics --zookeeper 127.0.0.1:2181 --partitions 1 --replication-factor 1 --create --topic __consumer_offsetskafka-topics.bat在kafka/bin/windows下一定记得执行命令后重启kafka服务。到此问题解决。希望对小伙伴们有帮助。