gpt4 book ai didi

apache-kafka - Kafka 高级消费者 error_code=15

转载 作者:行者123 更新时间:2023-12-04 14:55:32 25 4
gpt4 key购买 nike

当尝试使用高级消费者(使用全新的消费者组)从 Kafka 消费时,消费者永远不会开始运行。当我将日志记录级别切换到调试时,我可以看到以下两行一遍又一遍地重复:

DEBUG [AbstractCoordinator] 09:43:51.192: Sending coordinator request for group CompletelyNewConsumerGroupThatIneverUsedBefore to broker 172.30.3.61:30000 (id: 1043 rack: null)
DEBUG [AbstractCoordinator] 09:43:51.306: Received group coordinator response ClientResponse(receivedTimeMs=1487666631306, disconnected=false, request=ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@58f68932, request=RequestSend(header={api_key=10,api_version=0,correlation_id=197,client_id=consumer-1}, body={group_id=CompletelyNewConsumerGroupThatIneverUsedBefore}), createdTimeMs=1487666631192, sendTimeMs=1487666631192), responseBody={error_code=15,coordinator={node_id=-1,host=,port=-1}})

集群所有6个节点都正常消费数据。即使是旧的低级消费者也能工作。同样在 Zookeeper 中,应该只有 6 个节点,它们的日志文件看起来还可以。

通过谷歌搜索,我发现 error_code=15 意味着组协调器不可用。我认为这意味着消费者组协调员。这是回调问题吗?为什么高级消费者不工作?

最佳答案

事实证明,__consumer_offsets的所有分区主题位于死节点(我关闭并且永远不会回来的节点)。我通过关闭集群解决了这个问题,删除了 __consumer_offsets来自 Zookeeper 的主题,然后再次启动集群。

关于apache-kafka - Kafka 高级消费者 error_code=15,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42362911/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com