春季云流-消费者配置不起作用

Posted 2023-02-27

【中文标题】春季云流-消费者配置不起作用

【英文标题】：spring cloud stream- consumer config not working

【发布时间】：2019-07-18 16:25:36

【问题描述】：

我使用的是 spring boot 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

这是我的 i/o 通道接口。

interface EventStream 

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

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

【问题讨论】：

您的项目中的配置文件在哪里？您的项目是如何打包/执行的？

嗨@CraigOtis 我的配置存在于我的项目资源目录的application.yml 文件中。我的项目是gradle build。我解决了我将spring.cloud.stream.binding 更改为spring.cloud 的问题.stream.kafka.binding。你能告诉我这两个属性的差异以及我理解它们的差异的任何链接吗

【参考方案1】：

我认为在这种情况下 spring.cloud.stream.binding 和 spring.cloud.stream.kafka.binding 都适合你。似乎这是格式错误。请检查您的 yaml 文件格式并试一试。谢谢。

format is not correct