I'm using the Kafka Input plugin and noticed that my elasticsearch indices were being named incorrectly. After debugging, I realized that the kafka topic had documents that already included a type field. Input.conf input { kafka { type => "kafka" topic_id => "topic" zk_connect => "z…

Logstash Kafka Input Plugin Data has Type Already

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.

Logstash Kafka Input Plugin Data has Type Already