无法通过环境变量进行Spring Boot/Spring Kafka SSL配置

Question

我有一个与Kafka通信的Spring启动应用程序。

我通过注入环境变量在生产中配置这个应用程序。

对于kafka，我可以使用环境变量配置大多数内容—引导服务器、ssl信任库位置、ssl信任库密码、组id、主题，例如：

SPRING_KAFKA_SSL_TRUSTSTORE-LOCATION: "file:/opt/app/jks/totally_real_file.jks"
SPRING_KAFKA_SSL_TRUSTSTORE-PASSWORD: "hunter2"

因为我可以使用环境变量配置ssl密钥库和密码，所以我假设我可以配置ssl协议和安全协议；如：

SPRING_KAFKA_PROPERTIES_SECURITY_PROTOCOL: "SSL"
SPRING_KAFKA_PROPERTIES_SSL_PROTOCOL: "SSL"

但是，我会错误地假设，因为当我把它设置在那里时，会出现一条消息：

The configuration 'SECURITY_PROTOCOL' was supplied but isn't a known config
The configuration 'SSL_PROTOCOL' was supplied but isn't a known config

更多信息出现！

Bootstrap broker one:9093 disconnected
Bootstrap broker two:9093 disconnected
Bootstrap broker more_than_two:9093 disconnected

这让我很难过。我在网上搜索。我找到以下链接：

Spring启动application.yml中的Spring Kafka SSL设置

这没有多大帮助，我想通过环境变量进行配置。。。

我发现github存在链接问题（情况越来越糟）：

https://github.com/spring-projects/spring-integration-kafka/issues/157

这提供了部分线索。

基督教青年会：

spring.kafka.properties.security.protocol: "SSL"

应该行，但不行

基督教青年会：

spring:
  kafka:
    properties:
      security.protocol: "SSL"
      ssl.protocol: "SSL"

真管用！但不可能用环境变量来表示。

Answer 1

可能是环境变量名不正确。例如，与此相反：

SPRING_KAFKA_PROPERTIES_SECURITY_PROTOCOL

我想你应该使用生产者/消费者特定的名称，比如：

SPRING\u KAFKA\u PRODUCER\u PROPERTIES\u SECURITY\u PROTOCOL

或者

SPRING\u KAFKA\u CONSUMER\u PROPERTIES\u SECURITY\u PROTOCOL

Answer 2

我的解决方法是在application.yml中设置以下内容：

spring:
  kafka:
    properties:
      security.protocol: "SSL"
      ssl.protocol: "SSL"

我不喜欢这个解决方案，因为它需要我为prod和SIT构建不同的工件。（SIT Kafka没有启用SSL这一事实是另一天和另一杯酒的问题）

Answer 3

引导不可能考虑每一个可能的Kafka属性。有那么多。仅支持子集作为第一类属性。

可以使用系统属性而不是环境变量。

编辑

你可以这样做：

spring:
  kafka:
    properties:
      security.protocol: ${SEC_PROT}