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