Kinesis 消耗滞后监控

Question

我正在尝试在流级别收集 Kinesis 的指标，更具体地说，我想获取工作/消费者进程在流级别落后的计数，我不关心分片级别的滞后.我在 AWS 文档上找到了一个计算消费延迟的示例，但它计算的是延迟时间，而不是消息计数的延迟。我正在尝试使用 Java KCL 为流收集这些指标，这些指标将定期收集并发布到仪表板。谢谢。

Answer 1

按记录数计算的滞后大小不是您开箱即用的指标。你可以自己计算，但这并不简单。

生产者对消费者一无所知，消费者对生产者一无所知。延迟时间可用的唯一原因是每条记录的序列号都编码了摄取的时间戳，因此消费者可以发布他们看到的最新时间戳，然后您可以获得整个流的最大延迟。