定製 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.