Я работаю, получая помощь от следующего проекта:
Ниже приведен фрагмент кода application.yml:
spring:
cloud:
stream:
bindings:
ordersOut:
destination: test_stream
content-type: application/json
producer:
partitionKeyExpression: "1"
ordersIn:
destination: test_stream
content-type: application/json
Если я хочу включить свойства autoAddShards, minShardCount, куда это добавить.





Согласно AWS Kinesis Binder Документация у нас есть:
spring:
cloud:
stream:
kinesis:
binder:
autoAddShards: true
minShardCount: 10