如何为Spring-Cloud-starter-bus-kafka 1.2.0提供SSL配置。发布

Question

我使用的是Spring Boot 1.5.6。Spring Cloud Config 1.3.2发布。发布，Spring Cloud Starter Bus（Kafka）1.2.0。而Kafka的版本是0.10.1.1。我试图将其配置为使用两个启用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配置中对它们进行硬编码。我首选的方法是用jvm属性填充这些配置属性。

知道我做错了什么吗？

在尝试了各种事情之后，这里有一个有趣的更新。如果我创建了一个用@EnableKafkaStreams注释的@Configuration类，我可以创建一个StreamsConfig，它具有指定的所有配置的各种属性，但这会创建一个新的单独的生产者和消费者。Spring云总线Kafka生产者和消费者仍然没有配置超出默认值。

Answer 1

如果我遵循github的建议，将属性放入应用程序中。属性，而不是通过spring cloud config进行配置，它可以工作。通过spring cloud config配置的相同配置属性会导致配置崩溃，因为它似乎不喜欢属性名称中的括号。不过，它报告的错误并没有直接抱怨错误的属性键。当您仅通过spring boot执行此配置时，它似乎工作正常。所以，spring boot和spring cloud config之间的配置解析似乎存在差异。