Logstash kafka input plugin

Elastic Stack Logstash
1

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 {
stdout{}

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

2

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