在application.properties文件中配置自定义Kafka使用者反序列化程序。[Spring靴]

Question

我想使用 avro 消息并反序列化它们，而不使用融合模式注册表。我在本地有架构。因此，为此，我只关注消费者部分的 https://medium.com/@mailshine/apache-avro-quick-example-in-kafka-7b2909396c02。现在，我想在应用程序属性文件中配置此反序列化程序（Spring引导方式）。我尝试添加Spring.kafka.消费者.价值反序列化器=com.example.Avro去序列化器，但这会导致错误，说“找不到 com.example.Avro去序列化器的公共无参数构造函数”。有没有办法从应用程序属性配置中调用带有参数的构造函数。或者，我是否需要在代码中而不是属性中配置它？

提前致谢！！

Answer 1

你可以使用属性来做到这一点，但你必须通过配置方法（使用无arg构造函数）来做到这一点 - 这是因为Kafka实例化了反序列化器，而不是Spring。

有关示例，请参阅组织.springframework.kafka.support.serializer.JsonDeserizer 源代码。

否则，您可以将解串器注入消费者工厂...

@Bean
MyDeserializer(DefaultKafkaConsumerFactory<String, Foo> factory) {
    MyDeserializer<Foo> deser = new MyDeserializer<>(...);
    factory.setValueDeserializer(deser);
    return deser;
}