有时在连接具有相同组 ID 的第二个消费者后,我收到错误
“未找到消费者实例”(代码:40403)。
我注意到在连接第二个消费者时,我从两个消费者接收新消息的请求Kafka
都冻结了。我确信我得到的错误是问题的结果,而不是原因,因为在请求冻结后,消费者超时并自动删除。但是,我不明白为什么请求会挂起。
出现问题时,Kafka's
队列为空。
配置设置为:
zookeeper.connect
bootstrap.servers
其他值默认设置。
我认为这是由于消费者线程 ( consumer.threads
) 的限制,但文档说默认值为50
.