0

有时在连接具有相同组 ID 的第二个消费者后,我收到错误

“未找到消费者实例”(代码:40403)。

我注意到在连接第二个消费者时,我从两个消费者接收新消息的请求Kafka都冻结了。我确信我得到的错误是问题的结果,而不是原因,因为在请求冻结后,消费者超时并自动删除。但是,我不明白为什么请求会挂起。

出现问题时,Kafka's队列为空。

配置设置为:

zookeeper.connect
bootstrap.servers

其他值默认设置。

我认为这是由于消费者线程 ( consumer.threads) 的限制,但文档说默认值为50.

https://docs.confluent.io/current/kafka-rest/config.html

4

0 回答 0