自定义 AdminClient 配置
与上述消费者和生产者的配置自定义类似,应用程序也可以通过提供 AdminClientConfigCustomizer
来自定义 Admin 客户端的配置。
AdminClientConfigCustomizer 的 configure 方法提供了对 Admin 客户端属性的访问,您可以使用它来定义进一步的自定义。
Binder 的 Kafka topic provisioner 对通过此自定义器提供的属性赋予最高优先级。
以下是提供此自定义器 bean 的示例。
@Bean
public AdminClientConfigCustomizer adminClientConfigCustomizer() {
return props -> {
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");
};
}