How to made logstash work with io.confluent.kafka.serializers.KafkaAvroSerializer

Elastic Stack Logstash
1 
output{
   kafka{
     topic_id => "myTopic"
     bootstrap_servers => "127.0.0.1:9092"
     value_serializer => "io.confluent.kafka.serializers.KafkaAvroSerializer"
   }
}

[[main]-pipeline-manager] kafka - Unable to create Kafka producer from given configuration {:kafka_error_message=>org.apache.kafka.common.config.ConfigException: Invalid value io.confluent.kafka.serializers.KafkaAvroSerializer for configuration value.serializer: Class io.confluent.kafka.serializers.KafkaAvroSerializer could not be found., :cause=>nil}

Has anyone made logstash work with io.confluent.kafka.serializers.KafkaAvroSerializer

1 Like
2

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