我找不到任何说明如何与 Kinesis 增强型扇出集成的文档。 还是,有这种可能吗?
我的配置示例:
spring:
clouds:
streams:
bindings:
consumeRequest-in-0:
destination: dev-kinesis
content-type: application/json
group: dev-kinesis-grm
functions:
definition: consumeRequest
kinesis:
bindings:
consumeRequest-in-0:
consumer:
listener-mode: batch
records-limit: 100
shard-iterator-type: LATEST