|
对于最新稳定版本,请使用spring-cloud-stream 5.0.1! |
自定义消费者和生产者配置
如果您想要对用于创建 ConsumerFactory 和 ProducerFactory 的 Kafka 消费者和生产者的配置进行高级自定义,您可以实现以下定制器。
-
消费者配置自定义
-
生产者配置自定义器
这两个接口提供了一种方法来配置用于消费者和生产者属性的配置映射。
例如,如果您想访问在应用程序级别定义的bean,则可以将该bean注入到configure方法的实现中。
当binder发现这些自定义程序作为bean可用时,它将在创建消费者和生产者工厂之前调用configure方法。
这两个接口还提供了绑定和目标名称的访问,以便在自定义生产者和消费者属性时可以访问它们。