I have an ELK Set-up in which a logstash is pushing data to Kafka and another logstash is pulling data from Kafka. Below are my Kafka Input Config:- input { kafka { zk_connect => "kafka:2181" group_id => "logstash" topic_id => "logstash_logs" reset_beginning => …

Kafka.consumer.RangeAssignor: No broker partitions consumed by consumer thread logstash_logstash-indexer

Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant logo are trademarks of the Apache Software Foundation in the United States and/or other countries.

Kafka.consumer.RangeAssignor: No broker partitions consumed by consumer thread logstash_logstash-indexer