Kinesis 是否保证交货？

Question

我正在搜索 Kinesis Data Streams 的文档，但找不到像

这样的明确声明

Kinesis 保证至少一次交货

从生产者方面，我希望发送的消息会传播到多个节点（类似于 Kafka 的 ack=all） 从消费者方面来看，我期望消费者成功处理后的 Kafka 提交偏移量，或者类似于 Google Cloud 的 Pub/Sub 消息确认。

Kinesis 是否有提交消息保证？ Kinesis 是否有处理保证（仅在处理并确认已处理后将消息标记为只读）

Answer 1

基于 Kinesis 的文档使用者从 Stream 中读取整个数据。 因此，消费者有责任提交他们的历史并从他们离开的地方拾起。 https://docs.aws.amazon.com/streams/latest/dev/building-consumers.html

Answer 2

从 cmets 来看，如果您真的追求无服务器方法，为什么不使用 Lambda Event source mapping 来消费 Kinesis 消息？

• Lambda/AWS 将轮询消息，对它们进行批处理并调用我们的 lambda 函数来获取一批记录（批大小小至 1）。
• 如果 Lambda 函数返回成功，将提交批处理并为下一个批处理调用函数。
• 如果 Lambda 函数返回失败，可以停用批处理。
• 与 Kafka 消费者不同，我们需要将重试异常与另一个 kafka 主题或数据库分开处理，以保持消费者向前发展，AWS Lambda 也支持异步退休。

对于一个简单的用例，Kinesis + Lambda 与 Kafka + Consumer 一样好。