Facing issues in starting Logstash using kafka input plugin and avro codec

Elastic Stack Logstash
1

Hi,
I am entirely new to Logstash and elasticsearch
Currently I am facing a problem creating LS pipeline using kafka input which receives an avro message.

LS_Error
LS_Error.JPG1422×89 49.1 KB

The following is the configuration that is being used.

input {
kafka{
bootstrap_servers => "localhost:9092"
group_id => "logstashgroup"
codec => {
avro => {
schema_uri => 'path\to\avro\schema\file.avsc'
}
}
value_deserializer_class => "path\to\avro\deserializer\class\AvroDeserializer.class"
topics => "kafka_topic1"
}
}
output {
stdout { }
elasticsearch { hosts => "localhost:9200"
index => "kafka_topic1_index"}
}

Installed:
logstash-5.5
logstash-input-kafka 5.1.8
logstash-output-elasticsearch 7.3.6
logstash-codec-avro 3.2.1
elasticsearch-5.5

Any help from the community is a motivation !

Thanks.

2

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