定制 AdminClient 配置

与上面的消费者和生产者配置定制类似,应用程序也可以通过提供一个 AdminClientConfigCustomizer 来定制 admin client 的配置。AdminClientConfigCustomizer 的 configure 方法提供对 admin client 属性的访问,你可以使用它来定义进一步的定制。Binder 的 Kafka topic provisioner 对通过此定制器提供的属性具有最高的优先级。这里是一个提供此定制器 Bean 的示例。

@Bean
public AdminClientConfigCustomizer adminClientConfigCustomizer() {
    return props -> {
        props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");
    };
}