如果我在线程内运行kafka消费者,而不从外部操作它,比如让消费者休眠或唤醒他,那么有必要正确地处理WakeupException吗?什么是处理它的好方法?消费者运行在and服务上,不断地从队列中拉出数据,并且永远不应该停止这样做。此外,服务没有空闲或挂起状态。在Kafka的文档中指出,只有当kafka消费者被另一个线程阻塞时才会抛出异常,但这种情况永远不会发生。Kafka版本0.10.0.0
ca
我使用手动kafka commit,将属性enable.auto.commit设置为false,同时初始化Kafka消费者,并在接收和处理消息后手动调用kafka commit。然而,因为在我的消费者中处理消息是很耗时的,所以我得到了Exception with message "error": "Broker: Group rebalance in progress"
原因是重新平衡超时后提交被拒绝另一种方法是捕获此异常