我们有三节点Kafka集群。如果我们从集群中删除其中一个节点,那么剩下的两个节点将不会使用数据。它挂起来了。
我们在消费者控制台收到以下信息:
WARN Auto offset commit failed for group console-consumer-26249: Offset commit failed with a retriable exception. You should retry committing offsets. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
我们尝试了以下属性。但没用。
enble.auto.commit = true
auto.commit.interval.ms = 1000
offsets.commit.timeout.ms=50000 @ server.properties at each brokers
env:0.10.1.1和linux机器
如果我们启动了该服务,不管是哪一个,那么所有人都在尝试自动消费数据。
有什么问题吗
暂无答案!
目前还没有任何答案,快来回答吧!