Indexing data from kafka to elasticsearch


(B S) #1

Hi,
I am trying to index data from an existing topic in kafka to elasticserach. I am using the kafka input plugin in my logstash pipeline . Providing the below
bootstrap_servers => "localhost:port"
topics => "topic_name"

But the index is not getting created in elasticsearch nor am i getting any errors in my logstash logs.