定制 AdminClient 配置

与上述消费者和生产者配置自定义一样,应用程序还可以通过提供 AdminClientConfigCustomizer 来自定义 admin 客户端的配置。AdminClientConfigCustomizer 的 configure 方法允许访问 admin 客户端属性,您可以使用它来定义进一步的自定义。Binder 的 Kafka 主题配置程序为通过此自定义程序提供的属性赋予最高优先级。以下是提供此自定义程序 bean 的示例。

@Bean
public AdminClientConfigCustomizer adminClientConfigCustomizer() {
    return props -> {
        props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");
    };
}
© . This site is unofficial and not affiliated with VMware.