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工作吗?
1条答案
按热度按时间ffdz8vbo1#
您需要使用bytearrayserializer并安装此编解码器
https://github.com/revpoint/logstash-codec-avro_schema_registry