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

如果你想要高级自定义用于在 Kafka 中创建 ConsumerFactoryProducerFactory 的消费者和生产者配置,你可以实现以下自定义器。

  • ConsumerConfigCustomizer

  • ProducerConfigCustomizer

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

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