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