spring-未应用云流安全协议配置
spring-cloud-stream security protocol configuration not applied
我正在尝试配置 Kafka 活页夹的安全协议。如 spring-cloud-stream 参考中所述,security.protocol 属性 应该存在于 spring.cloud.stream.kafka.binder.configuration 层次结构中,但未应用此配置。
我收到以下警告:
**
WARN 17375 --- [ main] o.a.k.clients.consumer.ConsumerConfig
: The configuration 'security' was supplied but isn't a known config.
**
我的 yaml 片段:
spring:
cloud:
stream:
kafka:
binder:
brokers: localhost
defaultBrokerPort: 9092
zkNodes: localhost
defaultZkPort: 2181
minPartitionCount: 2
replicationFactor: 1
autoCreateTopics: true
autoAddPartitions: true
headers: type,message_id
requiredAcks: 1
configuration:
security:
protocol: SSL
我尝试调试属性的加载,看起来这个 属性 正在拆分,配置映射类似于:{"security" : {"protocol" : "SSL"}} 而不是 {"security.protocol" : "SSL"}。
我还尝试将 yaml 文件更改为:
configuration:
security.protocol: SSL
但是没有区别。
编辑: Spring Cloud Stream 版本是 Chelsea.SR2,Spring Boot 版本是 1.5.4.RELEASE.
这里报告了一个类似的问题:https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/129。
我们正在调查这是否是 Spring Cloud Stream 或 Spring Boot 中的问题。
我正在尝试配置 Kafka 活页夹的安全协议。如 spring-cloud-stream 参考中所述,security.protocol 属性 应该存在于 spring.cloud.stream.kafka.binder.configuration 层次结构中,但未应用此配置。
我收到以下警告:
**
WARN 17375 --- [ main] o.a.k.clients.consumer.ConsumerConfig : The configuration 'security' was supplied but isn't a known config.
**
我的 yaml 片段:
spring:
cloud:
stream:
kafka:
binder:
brokers: localhost
defaultBrokerPort: 9092
zkNodes: localhost
defaultZkPort: 2181
minPartitionCount: 2
replicationFactor: 1
autoCreateTopics: true
autoAddPartitions: true
headers: type,message_id
requiredAcks: 1
configuration:
security:
protocol: SSL
我尝试调试属性的加载,看起来这个 属性 正在拆分,配置映射类似于:{"security" : {"protocol" : "SSL"}} 而不是 {"security.protocol" : "SSL"}。
我还尝试将 yaml 文件更改为:
configuration:
security.protocol: SSL
但是没有区别。
编辑: Spring Cloud Stream 版本是 Chelsea.SR2,Spring Boot 版本是 1.5.4.RELEASE.
这里报告了一个类似的问题:https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/129。
我们正在调查这是否是 Spring Cloud Stream 或 Spring Boot 中的问题。