定製 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");
    };
}