监控消费者延迟
通过监控使用器延迟,您可以识别速度缓慢或卡住的使用器,这些使用器没有跟上主题中可用的最新数据。必要时,您可以采取补救措施,例如扩展或重启这些使用器。要监控使用器延迟,您可以使用 Amazon CloudWatch 或 Prometheus 的开源监控系统。
使用器延迟指标可以量化写入主题的最新数据与应用程序读取的数据之间的差异。Amazon MSK 提供以下使用器延迟指标,您可以通过 Amazon CloudWatch 或通过 Prometheus 的开源监控系统获得这些指标:EstimatedMaxTimeLag
、EstimatedTimeLag
、MaxOffsetLag
、OffsetLag
和 SumOffsetLag
。有关这些指标的信息,请参阅使用 CloudWatch 进行监控的 Amazon MSK 指标。
注意
消费者延迟指标仅对处于 STABLE 状态的消费者组可见。成功完成重新平衡后,消费者组处于 STABLE 状态,确保分区在消费者之间均匀分布。
Amazon MSK 支持采用 Apache Kafka 2.2.1 或更高版本的集群的使用器延迟指标。