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

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

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

  1. spring:
  2. cloud:
  3. stream:
  4. bindings:
  5. point-output-channel:
  6. destination: DST4-topic
  7. point-input-channel:
  8. destination: SRC4-topic
  9. kafka:
  10. streams:
  11. bindings:
  12. point-output-channel:
  13. producer:
  14. bufferSize: 14000
  15. binder:
  16. brokers: localhost:9092
  17. configuration:
  18. commit.interval.ms: 10000
  19. state.dir: state-store
  20. default:
  21. key:
  22. serde: org.apache.kafka.common.serialization.Serdes$StringSerde
  23. value:
  24. serde: org.apache.kafka.common.serialization.Serdes$StringSerde

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

暂无答案!

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

相关问题