我想在使用者属性中将默认值覆盖为下面列出的值,但我看不到这些更改得到反映。我希望我会得到一个例外,因为该服务将无法在10秒内处理500条消息。不确定,如果这是正确的配置方式。
spring:
cloud:
stream:
kafka:
bindings:
test-topic:
consumer:
configuration:
max.poll.records: 500
max.poll.interval.ms: 10000
暂无答案!
目前还没有任何答案,快来回答吧!