весенний облачный поток - потребительский конфиг не работает

Question

Я использую версию весенней загрузки 2.0.3-RELEASE.Это мой конфигурационный файл.Когда я запускаю своего потребителя, он запускается с конфигурацией по умолчанию. Они не переопределяются указанной конфигурацией.

spring:
  cloud:
    stream:
      kafka:
        binder:
          brokers: localhost
          defaultBrokerPort: 9092
          zkNodes: localhost
          defaultZkPort: 2181
       bindings:
         inEvent:
           consumer:
             configuration:
               max:
                 poll:
                   records: 10
               group:
                 id: group1
               client:
                 id: 1
               enable:
                 auto:
                   commit: true
               auto:
                 offset:
                   reset: earliest
           group: eventin
           destination: event
         inSenser:
           consumer:
             configuration:
               max:
                 poll:
                   records: 10
               client:
                 id: 2
           group: insenser
           destination: processenser

Это мой интерфейс ввода-вывода.

interface EventStream {

    @Input("inEvent")
    fun getEvents(): SubscribableChannel

    @Input("inSenser")
    fun getSensers(): SubscribableChannel
}

Answer 1

Я думаю, что как spring.cloud.stream.binding, так и spring.cloud.stream.kafka.binding будут работать в этом случае.Кажется, это ошибка формата.Пожалуйста, проверьте формат файла yaml и попробуйте.Спасибо.

неверный формат