Issue with Kafka input with Logstash

[SJN8 (Shashank Jain)]

Hi All,

I am using Kafka as input for Logstash , with below configuration to consume topics

input {
kafka {
zk_connect => {"localhost:2181"}
topic_id => {"ITSB"}
}
}

but i am not able to start Logstash , getting below error

[2017-12-12T12:26:53,902][ERROR][logstash.agent ] Failed to execute action {:action=>LogStash::PipelineAction::Create/pipeline_id:main, :exception=>"LogStash::ConfigurationError", :message=>"Expected one of #, => at line 3, column 36 (byte 54) after input {\n kafka {\n zk_connect => {"localhost:2181"",

can someone please help on the same ?
also let know if more details are required .

looks like syntax issue but i am not able to figure it out .

[Jon_D (Jonas D)]

Hello,

try this :

input {
     kafka {
            bootstrap_servers => "host1:port,host2:port"
            topics => ["topicname"]
        }
}

Port will be the kafka port (9092) if you didn't change it.

The zk_connect parameter in consumer configs is deprecated as far as I know.

Hope this helps,
regards,
Jonas