Indexing data from kafka to elasticsearch

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.

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.