在Spring配置文件中配置AvroSerializer声明,可以使用如下代码示例:
需要注意的是,value.serializer的值应该设置为io.confluent.kafka.serializers.KafkaAvroSerializer(假设使用的是Confluent平台)。同时,schema.registry.url需要设置为正确的schema registry地址。
上一篇:AvroSerializer:订单簿快照的模式
下一篇:Avro生产者发送无键模式的键