Springブート - リモートZookeperの設定

Question

私たちのSpringブートプログラムでは、ローカルZookeeperとApache Kafkaのサーバをリモートのものに切り替える（現時点ではcloudkarafkaだが、それは重要ではない）。

このプロバイダからは、ブートストラップサーバなどのリモートKafkaを使用するためにプロパティKafka設定マップに追加する必要があるプロパティがダウンロードされましたが、この後、Spring BootはローカルマシンのZookeeperの検索を続けます。何か私にできることはありますか？

application.yml

spring: 
cloud: 
    zookeeper: 
    connect-string: server:2181 

プロパティマップ

Map<String, Object> props = new HashMap<>(); 
    props.put("bootstrap.servers", getBrokers()); 
    props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, false); 
    props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "100"); 
    props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "15000"); 
    props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class); 
    props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class); 
    props.put("security.protocol", "SSL"); 
    props.put("ssl.truststore.location", "truststore.jks"); 
    props.put("ssl.truststore.password", "test1234"); 
    props.put("ssl.keystore.location", "keystore.jks"); 
    props.put("ssl.keystore.password", "pass"); 
    props.put("ssl.keypassword", "pass"); 
    props.put("zk.connect", "server:2181"); 

ありがとうございました。

Answer 1

cloudkarafka固有の設定についてはわかりません。しかし、これは私の開発環境にリモートカフカサーバーを接続している間に、これは直前に直面していた構成上の問題です。

kafka server.propertiesには2つのコメント設定があります。

#listeners=PLAINTEXT://:9092 
#advertised.listeners=PLAINTEXT://your.host.name:9092 

コメントを外して実際のIPアドレスを設定する必要があります。

リスナー設定は、ソケットサーバーがリッスンするアドレスです。設定されていない場合、java.net.InetAddress.getCanonicalHostName（）から返される値を取得します。これはlocalhostであり、クライアントがlocalhostを探す理由です。