Logstash kafka input plugin

Hi All,

I am new to logstash and was trying to use it to ingest data from an existing kafka topic.

I am using the following conf :
input {
kafka {
topics => "test"
bootstrap_servers => "X.X.X.X:9092"
codec => "json"
auto_offset_reset => "earliest"
output {

However none of the kafka messages are being shown in console. With debug option, I get this message - "Pushing flush onto pipeline".

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