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.