时间戳

首页 > 解决方案 > 如何使logstash与io.confluent.kafka.serializers.KafkaAvroSerializer一起工作

serialization - 如何使logstash与io.confluent.kafka.serializers.KafkaAvroSerializer一起工作

问题描述

   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}

有没有人让 logstash 与 io.confluent.kafka.serializers.KafkaAvroSerializer 一起工作？

标签： serializationapache-kafkalogstashlogstash-configurationkafka-serializer

解决方案

您需要使用 ByteArraySerializer 并安装此编解码器

https://github.com/revpoint/logstash-codec-avro_schema_registry

推荐阅读