自訂 AdminClient 組態

如同上述的消費者和生產者組態自訂,應用程式也可以透過提供 AdminClientConfigCustomizer 來為管理用戶端自訂組態。AdminClientConfigCustomizer 的 configure 方法提供對管理用戶端屬性的存取權,您可以使用這些屬性來定義進一步的自訂。Binder 的 Kafka 主題佈建器為透過此自訂器提供的屬性提供最高優先權。以下是提供此自訂器 Bean 的範例。

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