|
该版本仍在开发中，尚未被视为稳定。对于最新稳定版本，请使用 spring-cloud-stream 5.0.0！ |
定制AdminClient配置
与上述消费者和生产者配置自定义一样，应用程序也可以通过提供AdminClientConfigCustomizer.
AdminClientConfigCustomizer 的配置方法提供了访问管理员客户端属性的权限，您可以通过这些属性定义进一步的自定义。
Binder 的 Kafka 主题 provisioner 为该定制器提供的属性提供了最高优先级。
这里有一个提供这种定制豆的示例。
@Bean
public AdminClientConfigCustomizer adminClientConfigCustomizer() {
return props -> {
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");
};
}