0

私はSpringブート1.5.6.RELEASE、Spring Cloud Config 1.3.2.RELEASE、およびSpring Cloud Starter Bus(Kafka )1.2.0.RELEASE、カフカ版は0.10.1.1です。私は2つのSSL対応のブローカーを使用するように設定しようとしていますが、私はこのようになります警告メッセージの反復配列(各ブローカーに1つ)になってしまう:私の構成ではspring-cloud-starter-bus-kafka 1.2.0.RELEASEにSSL設定を提供する方法

Bootstrap broker broker1:9993 disconnected 
Bootstrap broker broker2:9993 disconnected 

を、私が持っています(ただ、関連する部分はここに含まれています):

spring: 
    cloud: 
     stream: 
      kafka: 
       binder: 
        zkNodes: zkhost1:2181,zkhost2:2181 
        brokers: broker1:9993,broker2:9993 
        configuration: 
         security.protocol: SSL 
         ssl.enabled.protocols: TLSv1.1,TLSv1.2 
         ssl.endpoint.identification.algorithm: HTTPS 

ProducerConfigとConsumerConfigは、その設定値を吐き出すときしかし、彼らの両方が示されます

security.protocol = PLAINTEXT 
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] 
ssl.endpoint.identification.algorithm = null 

また、私が手次の警告メッセージ:

The configuration 'key.deserializer' was supplied but isn't a known config. 
The configuration 'value.deserializer' was supplied but isn't a known config. 
The configuration 'ssl' was supplied but isn't a known config. 
The configuration 'security' was supplied but isn't a known config. 

は私がトラストストア、ストア、およびそのパスワードや店舗の種類の設定を追加する必要がありますつもりです、と私はまた、それらをハードコーディングせずに、これらを提供する方法を知りたいですyaml configs。私の好みの方法は、これらの設定プロパティにjvmプロパティを設定することです。

私が間違っていることを知っていますか?

さまざまなことを試した後、面白いアップデートです。 @EnableKafkaStreamsでアノテーションされた@Configurationクラスを作成した場合、指定されたすべてのさまざまなプロパティでStreamsConfigを作成できますが、これによって新しい独立したプロデューサとコンシューマが作成されます。春のクラウド・バス・カフカ・プロデューサーと消費者は、依然としてデフォルトを超えて構成されていません。

答えて

0

私がgithubのアドバイスに従って、そのプロパティをjarのapplication.propertiesに入れ、spring-cloud-configで設定しないとうまくいきます。 spring-cloud-configで設定された同じ設定プロパティは、プロパティ名の角括弧のように見えないため、設定をクラッシュさせます。しかし、それが報告するエラーは、不正なプロパティキーについて直接不平を言うことはありません。 spring-bootでのみこの設定を行うとうまくいくようです。ですから、spring-bootとspring-cloud-configの間で設定解析に不一致があるようです。

関連する問題