Spring Kafka - 覆盖作为对象提供的 ConsumerFactory 的反序列化器 Class
Spring Kafka - Override ConsumerFactory's Deserializer Class provided as an object
如果作为对象而不是属性中的 class 名称提供,是否可以覆盖 ConsumerFactory 配置的反序列化器?也许在 ContainerCustomizer 中?
没有;这是不可能的 - 提供对象的唯一方法是在创建消费者之前通过工厂构造函数或设置器;您根本无法覆盖这些,即使使用属性也无法覆盖,因为它们直接传递给 KafkaConsumer
并且将使用它们而不是属性中指定的任何内容。
参见ConsumerConfig.appendDeserializerToConfig()
。
如果你想用对象覆盖默认值,你需要使用不同的消费者工厂。
如果作为对象而不是属性中的 class 名称提供,是否可以覆盖 ConsumerFactory 配置的反序列化器?也许在 ContainerCustomizer 中?
没有;这是不可能的 - 提供对象的唯一方法是在创建消费者之前通过工厂构造函数或设置器;您根本无法覆盖这些,即使使用属性也无法覆盖,因为它们直接传递给 KafkaConsumer
并且将使用它们而不是属性中指定的任何内容。
参见ConsumerConfig.appendDeserializerToConfig()
。
如果你想用对象覆盖默认值,你需要使用不同的消费者工厂。