Que fait Runbook de Retard de Consommateurs Apache Kafka ?
Diagnostique le retard des groupes de consommateurs Kafka via l'API AdminClient et les métriques JMX exposées par l'API Confluent Metrics. Identifie les consommateurs lents, les points chauds de partition et les tempêtes de rééquilibrage des brokers qui contribuent à l'augmentation du retard. Fournit un runbook étape par étape pour ajuster fetch.min.bytes, max.poll.records et le nombre de partitions.
Prérequis
Java
Installation
Utilisez la méthode d'installation ou de configuration appropriée à votre environnement :
- docker run -p 9092:9092 apache/kafka:latest
Exigences et notes issues de la source amont :
- Utilisation de l'image Docker :
- Voir docker/README.md pour des informations détaillées.
Notes de base pour la prise en main :
-
Construire un JAR et l'exécuter
-
Exécuter les tests unitaires et d'intégration
-
./gradlew test -Pkafka.test.run.flaky=true # exécute les tests marqués comme instables
-
Source : https://github.com/apache/kafka
-
Extrait de la documentation amont : https://raw.githubusercontent.com/apache/kafka/HEAD/README.md