我正在搜索 Kinesis Data Streams 的文档,但找不到像
Kinesis 保证至少交付一次
从生产者方面,我希望发送的消息传播到多个节点(类似于 Kafka 的 ack=all)从消费者方面,我希望从消费者或 Google 之类的成功处理中得到与 Kafka 提交偏移相当的东西Cloud 的 Pub/Sub 消息确认。
Kinesis 是否有提交消息保证?Kinesis 是否有处理保证(仅在处理并确认已处理时将消息标记为只读)
基于 Kinesis 的文档,消费者从 Stream 中读取了全部数据。因此,消费者有责任提交他们的历史记录并从他们离开的地方开始。 https://docs.aws.amazon.com/streams/latest/dev/building-consumers.html