私は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を作成できますが、これによって新しい独立したプロデューサとコンシューマが作成されます。春のクラウド・バス・カフカ・プロデューサーと消費者は、依然としてデフォルトを超えて構成されていません。