I have two logstash servers as front-end, with Kafka Output and two logstash servers as back-end with Kafka Input.
The front-ends are putting all events into one topic, theoretically the back-ends should read from the topic. In my case only one back-end servers can read from Kafka.
i was trying to set up Replicated ZooKeeper Cluster and Multi-broker cluster with replicated topic, and still have the same.
Can you help me, what I am doing wrong ?
Logstash Kafka Output:
topic_id => "logstash-logs-replicated"
broker_list => "xxx.xxx.xxx.xxx:9092"
Logstash Kafka Input:
topic_id => 'logstash-logs-replicated'