监控消费者延迟 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

监控消费者延迟

通过监控使用器延迟，您可以识别速度缓慢或卡住的使用器，这些使用器没有跟上主题中可用的最新数据。必要时，您可以采取补救措施，例如扩展或重启这些使用器。要监控使用器延迟，您可以使用 Amazon CloudWatch 或 Prometheus 的开源监控系统。

使用器延迟指标可以量化写入主题的最新数据与应用程序读取的数据之间的差异。Amazon MSK 提供了以下消费者延迟指标，您可以通过亚马逊 CloudWatch 或通过 Prometheus 的开放监控获得这些指标：、、、和。EstimatedMaxTimeLag EstimatedTimeLag MaxOffsetLag OffsetLag SumOffsetLag有关这些指标的信息，请参阅用于监控标准代理的 Amazon MSK 指标 CloudWatch。

注意

  • 只有当消费者组处于 STABLE 或 EMPTY 状态时，才会发出消费者滞后指标。成功完成重新平衡后，消费者组处于 STABLE 状态，确保分区在消费者之间均匀分布。

  • 在以下情况下，不存在消费者滞后指标：

    • 如果消费组不稳定。

    • 消费组的名称包含冒号（:）。

    • 您尚未为该消费者组设置消费者偏移量。

Amazon MSK 支持采用 Apache Kafka 2.2.1 或更高版本的集群的使用器延迟指标。