自定义消费者和生产者配置

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

  • ConsumerConfigCustomizer

  • ProducerConfigCustomizer

这两个接口都提供了一种配置用于消费者和生产者属性的配置映射(config map)的方式。例如,如果您想访问在应用层面定义的 bean,可以在 configure 方法的实现中注入它。当 Binder 检测到这些自定义器作为 bean 可用时,它将在创建消费者和生产者工厂之前立即调用 configure 方法。

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