Formations Big Data & Data Science

Durée 3 jours Obtenir un devis
Logo OfficielleOfficielle
Logo CertifianteProgramme

Fondamentaux

  • Les logs
  • La réplication des logs
  • Les concepts de Topics, Partitions et de Segments
  • Kafka Streams
  • Dualité entre les notions de Stream et Table• Stream–Table Dualism
  • Les jobs de Stream Processing

Cas d'utilisation de KSQL

  • Pourquoi KSQL
  • Exemples de cas d’utilisations
  • KSQL et licensing

Vue d'ensemble de KSQL et écosystème

  • KSQL & Kafka = Easy
  • Utilisation interactive de KSQL
  • Architecture de KSQL
  • KSQL CLI
  • Les modes serveur de KSQL
  • KSQL et Confluent Control Center (C3)

Utiliser KSQL

  • Kafka Streams et Tables
  • Message Kafka et Formats de données
  • Manipulation et agrégation de données
  • Fonctions définies par l'utilisateur (UDF)
  • Enrichissement des données et jointures
  • Agrégations fenêtrées (Windowed opération)
  • Métrique et observabilité
  • Tests et Monitoring
  • Astuces, pièges et limitations

Déploiement et utilisation de KSQL

  • Les bonnes pratiques et patterns
  • Sécuriser KSQL
  • Élasticité et évolutivité
  • Tolérance aux pannes
  • Healthcheck

Architecture de Kafka Streams

  • Motivation et évolution
  • Les caractéristiques
  • Liberté de choix

Kafka Streams Application Anatomie

  • Anatomie d’une application Streams
  • Configuration d’une,'application Streams
  • Topologie d’une application Streams

Kafka Streams DSL

  • Opérations Stateless et Stateful
  • Kafka Streams DSL
  • Les opération de type fenêtre glissante
  • L’API processeur

Test des applications Kafka Streams

  • Les catégories de test
  • Tests unitaires
  • Tests d'intégration avec Test Driver et Kafka embarqué

Surveillance des applications Kafka Streams

  • Utilisation de la surveillance basée sur JMX
  • Utilisation de Confluent Control Center pour la surveillance

Sécurisation des applications Kafka Streams

  • Pourquoi la sécurité est nécessaire
  • Aperçu de la sécurité
  • Fonctions de sécurité côté client
  • Les ACLs requis
  • Chiffrement des données en transit

Dimensionnement et mise à l'échelle des applications Kafka Streams

  • Scalabilité et élasticité
  • Définir le nombre d’instances par application
  • Gestion de la mémoire
  • Dimensionnement et positionnement des tâches
  • Stateless vs Stateful
  • Troubleshooting

Utilisation de l'API KSQL REST

  • Exemples de requête
  • Exemples de réponse