spring.cloud.stream.kafka.bindings.< channelname>.producer.configuration未应用

8cdiaqws  于 2021-08-20  发布在  Java
关注(0)|答案(0)|浏览(239)

我有一个用于流数据处理的小应用程序。我从一个主题接收数据,处理并写入另一个主题。我在java应用程序中使用SpringCloud和ApacheKafka。我想为生产者设置一些属性,比如buffersize。下面是我的应用程序的一个示例。yaml

spring:
  cloud:
    stream:
      bindings:
        point-output-channel:
          destination: DST4-topic
        point-input-channel:
          destination: SRC4-topic
      kafka:
        streams:
          bindings:
            point-output-channel:
              producer:
                bufferSize: 14000
          binder:
            brokers:  localhost:9092
            configuration:
              commit.interval.ms: 10000
              state.dir: state-store
              default:
                key:
                  serde: org.apache.kafka.common.serialization.Serdes$StringSerde
                value:
                  serde: org.apache.kafka.common.serialization.Serdes$StringSerde

但是buffersize值没有应用于生产者,有什么问题吗?非常感谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题