我正在研究合流和Kafka休息代理。我已经把它安装在本地的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消费者卡在(重新)加入组,但它没有帮助。
请指导我如何解决这个问题。
1条答案
按热度按时间ou6hu8tu1#
游戏后期,Zookeeper和经纪人帮助解决了这个问题。