小编Kum*_*ish的帖子

将带有参数的案例类作为案例类转换为 Avro 消息以发送到 Kafka

我正在使用具有嵌套案例类的案例类,Seq[Nested Case Classes] 问题是当我尝试使用它进行序列化时,KafkaAvroSerializer它会抛出:

Caused by: java.lang.IllegalArgumentException: Unsupported Avro type. Supported types are null, Boolean, Integer, Long, Float, Double, String, byte[] and IndexedRecord
    at io.confluent.kafka.serializers.AbstractKafkaAvroSerDe.getSchema(AbstractKafkaAvroSerDe.java:115)
    at io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.serializeImpl(AbstractKafkaAvroSerializer.java:71)
    at io.confluent.kafka.serializers.KafkaAvroSerializer.serialize(KafkaAvroSerializer.java:54)
    at org.apache.kafka.common.serialization.Serializer.serialize(Serializer.java:60)
    at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:879)
    at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:841)
    at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:728)```
Run Code Online (Sandbox Code Playgroud)

scala avro apache-kafka confluent-platform

5
推荐指数
1
解决办法
634
查看次数

标签 统计

apache-kafka ×1

avro ×1

confluent-platform ×1

scala ×1