自定义AdminClient配置
与上面消费者和生产者配置自定义一样,应用程序还可以通过提供一个`AdminClientConfigCustomizer`来自定义admin客户端的配置。`AdminClientConfigCustomizer`的`configure`方法提供了对admin客户端属性的访问,您可以使用它来定义进一步的自定义。绑定器的Kafka主题提供者对通过此自定义程序提供的属性具有最高优先级。这是一个提供此自定义程序bean的示例。
@Bean
public AdminClientConfigCustomizer adminClientConfigCustomizer() {
return props -> {
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");
};
}