Configurer Data Streams Monitoring pour Java

La solution Data Streams Monitoring n'est pas prise en charge dans la région AP1.

Prérequis

Pour implémenter la solution Data Streams Monitoring, vous devez avoir installé la dernière version de l’Agent Datadog et des bibliothèques Java :

Installation

Java se sert de l’instrumentation automatique afin d’injecter et d’extraire les métadonnées supplémentaires requises par Data Streams Monitoring pour mesurer les latences de bout en bout ainsi que la relation entre les files d’attente et les services. Pour activer Data Streams Monitoring, définissez la variable d’environnement DD_DATA_STREAMS_ENABLED sur true sur les services qui envoient des messages à Kafka ou RabbitMQ (ou qui consomment des messages à partir de ces plateformes).

Exemple :

environment:
  - DD_DATA_STREAMS_ENABLED: "true"

Vous pouvez également définir la propriété système -Ddd.data.streams.enabled=true en exécutant la ligne suivante au lancement de votre application Java :

java -javaagent:/chemin/vers/dd-java-agent.jar -Ddd.data.streams.enabled=true -jar chemin/vers/votre/application.jar

Installation en un clic

Pour configurer Data Streams Monitoring à partir de l’interface utilisateur de Datadog sans avoir à redémarrer votre service, utilisez la configuration à lʼexécution. Accédez à la page du service APM et Enable DSM.

Activer la solution Data Streams Monitoring depuis la section Dépendances de la page du service APM

Bibliothèques compatibles

Data Streams Monitoring prend en charge la bibliothèque confluent-kafka.

Surveiller des pipelines SQS

La solution Data Streams Monitoring utilise un attribut de message pour suivre le parcours d’un message dans une file d’attente SQS. Amazon SQS ayant une limite maximale de 10 attributs de message autorisés par message, tous les messages transmis par les pipelines de données doivent avoir 9 attributs de message ou moins définis, ce qui permet à Data Streams Monitoring d’utiliser l’attribut restant.

Pour aller plus loin

Documentation, liens et articles supplémentaires utiles: