Я пытаюсь настроить протокол безопасности связывателя Kafka. Как описано в справочнике spring-cloud-stream, свойство security.protocol должно существовать в иерархии spring.cloud.stream.kafka.binder.configuration, но эта конфигурация не применяется. Я получаю следующее предупреждение:
**
WARN 17375 --- [main] o.a.k.clients.consumer.ConsumerConfig: Конфигурация «безопасность» была предоставлена, но не является известной конфигурацией.
**
Мой фрагмент 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.