自定义消费者和生产者配置
如果你想对 Kafka 中用于创建 ConsumerFactory
和 ProducerFactory
的消费者和生产者配置进行高级自定义,你可以实现以下自定义器。
-
ConsumerConfigCustomizer
-
ProducerConfigCustomizer
这两个接口都提供了一种配置用于消费者和生产者属性的配置映射的方式。例如,如果你想访问在应用程序级别定义的 bean,你可以将其注入到 configure
方法的实现中。当绑定器发现这些自定义器作为 bean 可用时,它将在创建消费者和生产者工厂之前调用 configure
方法。
这两个接口还提供了对绑定名称和目标名称的访问,以便在自定义生产者和消费者属性时可以访问它们。