監控消費者延遲 - Amazon Managed Streaming for Apache Kafka

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

監控消費者延遲

監控取用者延遲使您可以識別緩慢或停滯的取用者，他們無法跟上主題中可用的最新資料。必要時，您可以採取補救措施，例如擴展或重新啟動這些取用者。若要監控取用者延遲，您可以使用 Amazon CloudWatch 或透過 Prometheus 進行開放式監控。

取用者延遲指標可量化寫入主題的最新資料，與應用程式讀取的資料之間的差異。Amazon MSK 提供下列取用者延遲指標，您可以透過 Amazon CloudWatch 或以 Prometheus 進行開放式監控取得它們：EstimatedMaxTimeLag、EstimatedTimeLag、MaxOffsetLag、OffsetLag 和。SumOffsetLag如需這些指標的相關資訊，請參閱 使用 CloudWatch 監控標準代理程式的 Amazon MSK 指標。

Amazon MSK 支援針對採用 Apache Kafka 2.2.1 及更高版本的叢集使用取用者延遲指標。當您使用 Kafka 和 CloudWatch 指標時，請考慮下列事項：

  • 只有當取用者群組處於 STABLE 或 EMPTY 狀態時，才會發出取用者延遲指標。成功完成重新平衡後，取用者群組是 STABLE，確保分割區平均分佈在取用者之間。

  • 在下列案例中，消費者延遲指標不存在：

    • 如果取用者群組不穩定。

    • 取用者群組的名稱包含冒號 (：)。

    • 您尚未設定取用者群組的取用者位移。

  • 取用者群組名稱會用作 CloudWatch 中取用者延遲指標的維度。雖然 Kafka 在取用者群組名稱中支援 UTF-8 字元，但 CloudWatch 僅支援維度值的 ASCII 字元。如果您在取用者群組名稱中使用非 ASCII 字元，CloudWatch 會捨棄取用者延遲指標。為了確保您的取用者延遲指標在 CloudWatch 中正確擷取，您必須在取用者群組名稱中僅使用 ASCII 字元。