Hi! I have pipeline kafka→logstash→Elasticsearch I created two topics in kafka: test-1 and test-2 Write manually to these topics messages: 67 into test-1 and 67 into test-2. I wrote two logstash workers test1.conf input { kafka { bootstrap_servers => "172.29.39.115:9093,172.29.39.11…

Logstash concatinates topics

Badger November 24, 2021, 5:38pm 2

See this answer.

Elasticsearch is a trademark of Elasticsearch BV, registered in the U.S. and in other countries
Trademarks
Terms
Privacy
Brand
Code of Conduct

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.