Hi, I had a Kafka cluster with three brokers.
I killed two of them by mistake. I restarted them with the same server.properties config files that was used in running them the first time, but it is not functioning correctly. By this I mean when I run bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic <topic_name> --from-beginning, it prints nothing, although when I replace the localhost with the address of broker server that had not been killed in --zookeeper localhost:2181, it has all the messages. It seems like the two restarted Kafka brokers are not finding which cluster they should belong. How can I fix this? Also, how do brokers in a cluster recognize each other's address? By zookeeper.connect field in server.properties file? Best, Eric
