2017-12-15 10: 57: 28.785 INFO 1731 --- [_consumer-1-C-1] oakccinternals.AbstractCoordinator: Coordinator designation 172.16.111.128:9092 (id: 2147483647 rack: null) dead for springkafkatest
Hi, I have 3 brokers in a cluster, say broker 0, broker 1 and broker 2. I start them one by one. therefore, broker 0 will be the coordinator. Now I'm trying to kill broker 0. And I get the message above. If I kill broker 1 or broker 2, it works fine. I thought that he should automatically detect my other broker as a new coordinator. However, it is not. Am I missing any settings? By the way, I am using spring-kafka 1.2.3
source
share