此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 spring-cloud-stream 4.1.4! |
自定义 Consumer 和 Producer 配置
如果您希望对用于创建ConsumerFactory
和ProducerFactory
在 Kafka 中,
您可以实施以下定制器。
-
ConsumerConfigCustomizer
-
ProducerConfigCustomizer
这两个接口都提供了一种配置用于 consumer 和 producer 属性的 config map 的方法。
例如,如果要访问在应用程序级别定义的 bean,则可以将其注入到configure
方法。
当 Binder 发现这些定制器可用作 bean 时,它将调用configure
方法。
这两个接口还提供对 binding 和 destination 名称的访问,以便在自定义 producer 和 consumer 属性时可以访问它们。