TRIM_HORIZON 对比最新 [英] TRIM_HORIZON vs LATEST

问题描述

我在 AWS Kinesis 的正式文档中找不到 TRIM_HORIZON 和检查点之间的任何显式 引用，以及它们之间的任何引用LATEST 和检查点.

I can't find in the formal documentation of AWS Kinesis any explicit reference between TRIM_HORIZON and the checkpoint, and also any reference between LATEST and the checkpoint.

你能证实我的理论吗:

• TRIM_HORIZON - 如果应用程序名称是新的，那么我将读取流中的所有可用记录.否则，application-name 已被使用，那么我将从 my 上次检查点读取.

• TRIM_HORIZON - In case the application-name is new, then I will read all the records available in the stream. Else, application-name was already used, then I will read from my last checkpoint.

LATEST - 如果应用程序名称是新的，那么我将读取流中添加的所有记录> 我订阅了这个流.否则，application-name 已被使用，我将从 my 上次检查点读取消息.

LATEST - In case the application-name is new, then I will read all the records in the stream which added after I subscribed to the stream. Else, application-name was already used, I will read messages from my last checkpoint.

TRIM_HORIZON 和 LATEST 之间的区别仅在于应用程序名称是新的.

The difference between TRIM_HORIZON and LATEST is only in case the application-name is new.

推荐答案

AT_TIMESTAMP

AT_TIMESTAMP

-- 来自特定时间戳

TRIM_HORIZON

TRIM_HORIZON

--Kinesis 流中所有可用消息从头开始(与 Kafka 中最早相同)

-- all the available messages in Kinesis stream from the beginning (same as earliest in Kafka)

最新

-- 来自最新消息，即刚刚进入 Kinesis/Kafka 的当前消息以及从那时起的所有传入消息 onwords

-- from the latest messages , i.e current message that just came into Kinesis/Kafka and all the incoming messages from that time onwords

这篇关于TRIM_HORIZON 对比最新的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！