View a markdown version of this page

Surveillez les retards des consommateurs - Amazon Managed Streaming for Apache Kafka

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Surveillez les retards des consommateurs

La surveillance du retard des consommateurs vous permet d'identifier les consommateurs lents ou bloqués qui ne suivent pas les dernières données disponibles dans une rubrique. Si nécessaire, vous pouvez ensuite prendre des mesures correctives, telles que la mise à l'échelle ou le redémarrage de ces consommateurs. Pour surveiller le retard des consommateurs, vous pouvez utiliser Amazon CloudWatch ou ouvrir la surveillance avec Prometheus.

Les métriques de retard des consommateurs quantifient la différence entre les dernières données écrites dans vos rubriques et les données lues par vos applications. Amazon MSK fournit les indicateurs de retard des consommateurs suivants, que vous pouvez obtenir via Amazon CloudWatch ou via une surveillance ouverte avec Prometheus :EstimatedMaxTimeLag,, etEstimatedTimeLag. MaxOffsetLag OffsetLag SumOffsetLag Pour en savoir plus sur ces métriques, consultez Statistiques Amazon MSK pour surveiller les courtiers Standard avec CloudWatch.

Amazon MSK prend en charge les métriques de retard des consommateurs pour les clusters utilisant la version 2.2.1 ou ultérieure d'Apache Kafka. Lorsque vous travaillez avec Kafka et les CloudWatch métriques, tenez compte des points suivants :

  • Les mesures de latence des consommateurs ne sont émises que si un groupe de consommateurs est dans un état STABLE ou VIDE. Un groupe de consommateurs est STABLE une fois le rééquilibrage effectué avec succès, ce qui garantit que les partitions sont réparties uniformément entre les consommateurs.

  • Les indicateurs de latence des consommateurs sont absents dans les scénarios suivants :

    • Si le groupe de consommateurs est instable.

    • Le nom du groupe de consommateurs contient deux points (:).

    • Vous n'avez pas défini de compensation pour le groupe de consommateurs.

  • Les noms des groupes de consommateurs sont utilisés comme dimensions pour les mesures de retard des consommateurs dans CloudWatch. Alors que Kafka prend en charge les UTF-8 caractères dans les noms de groupes de consommateurs, il ne CloudWatch prend en charge que les caractères ASCII pour les valeurs de dimension. Si vous utilisez des caractères non ASCII dans les noms de groupes de consommateurs, les indicateurs de décalage des CloudWatch consommateurs sont supprimés. Pour vous assurer que vos indicateurs de retard de consommation sont correctement capturés CloudWatch, vous devez utiliser uniquement des caractères ASCII dans les noms de vos groupes de consommateurs.