定制消费者和生产者配置

如果您希望对用于在 Kafka 中创建 ConsumerFactoryProducerFactory 的消费者和生产者配置进行高级自定义,您可以实现以下自定义器。

  • ConsumerConfigCustomizer

  • ProducerConfigCustomizer

这两个接口都提供了一种配置用于消费者和生产者属性的配置映射的方法。例如,如果您想访问在应用程序级别定义的 bean,您可以在 configure 方法的实现中注入它。当绑定器发现这些自定义器作为 bean 可用时,它将在创建消费者和生产者工厂之前调用 configure 方法。

这两个接口还提供了对绑定和目标名称的访问,以便在自定义生产者和消费者属性时可以访问它们。

© . This site is unofficial and not affiliated with VMware.