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