此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 spring-cloud-stream 4.1.4! |
自定义 AdminClient 配置
与上述 consumer 和 producer 配置自定义一样,应用程序也可以通过提供AdminClientConfigCustomizer
.
AdminClientConfigCustomizer 的 configure 方法提供对 admin 客户端属性的访问,您可以使用这些属性定义进一步的自定义。
Binder 的 Kafka 主题预置程序为通过此定制器提供的属性提供最高优先级。
以下是提供此定制器 bean 的示例。
@Bean
public AdminClientConfigCustomizer adminClientConfigCustomizer() {
return props -> {
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");
};
}