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