我在Confluent和Kafka REST代理上工作。我已经在本地的Macbook上安装了它。我可以使用REST代理发送(生产者)和接收(消费者)消息。很好。但是,有时它会抛出以下错误消息,
[2018-01-23 17:08:53,298] INFO [Consumer clientId=consumer-2, groupId=my_consumer] (Re-)joining group (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:336)我不确定为什么会发生这个错误?当我们在控制台中收到此错误消息时,无法发送和接收消息。我已经检查了这个查询,Kafka consumer stuck in (Re-)joining group,但是它没有帮助。
请指导我如何解决这个问题。
发布于 2020-08-14 03:18:11
在游戏后期,重新启动zookeeper和brokers帮助解决了这个问题。
https://stackoverflow.com/questions/48505731
复制相似问题