跳到主要内容
版本:5.0.1

自定义 AdminClient 配置

DeepSeek V3 中英对照 Customizing AdminClient Configuration

与上述消费者和生产者配置自定义类似,应用程序也可以通过提供 AdminClientConfigCustomizer 来自定义管理客户端的配置。AdminClientConfigCustomizer 的 configure 方法提供了对管理客户端属性的访问权限,您可以使用它来定义进一步的定制。Binder 的 Kafka 主题配置器将最高优先级赋予通过此自定义器提供的属性。以下是提供此自定义器 bean 的示例。

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