在用相同的组id连接第二个消费者之后,我得到了一个错误
“未找到使用者示例”(代码:40403)。
我注意到在连接第二个消费者时,我请求从 Kafka
对两个消费者都是冷冻的。我确信,我得到的错误是问题的结果,而不是原因,因为在请求冻结后,消费者会经历一个超时,并且它会被自动删除。但是,我不明白为什么请求挂起。
在出现问题的时候, Kafka's
队列为空。
配置设置为:
zookeeper.connect
bootstrap.servers
默认情况下会设置其他值。
我认为这是由于消费者线程的限制( consumer.threads
),但文档中说默认值是 50
.
https://docs.confluent.io/current/kafka-rest/config.html
暂无答案!
目前还没有任何答案,快来回答吧!