如何使日志存储与io.confluent.kafka.serializers.kafkaavroserializer一起工作

gjmwrych  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(490)
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}` 有人用io.confluent.kafka.serializers.kafkaavroserializer使logstash工作吗?
ffdz8vbo

ffdz8vbo1#

您需要使用bytearrayserializer并安装此编解码器
https://github.com/revpoint/logstash-codec-avro_schema_registry

相关问题