我有一个用于流数据处理的小应用程序。我从一个主题接收数据,处理并写入另一个主题。我在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值没有应用于生产者,有什么问题吗?非常感谢。
暂无答案!
目前还没有任何答案,快来回答吧!