KafkaConsumer group et rebalance dans Kafka avec Spring Boot
Comprendre comment Kafka divise les partitions parmi les consumer groups, quand un rebalance se produit et comment réduire son impact dans une application Spring Boot.
Change Data Capture avec Debezium et Kafka
Utilisez Debezium pour lire le WAL de PostgreSQL, envoyer tous les changements de données vers Kafka et les consommer avec Spring Boot, sans modifier le code d'écriture des données.
Event sourcing avec Kafka : enregistrer les événements plutôt que l'état
Utiliser Kafka comme event log pour Order : enregistrer les événements immuables, reconstruire l'état par replay, créer un read model par projection. Avec les limites à connaître avant d'appliquer.
Kafka producer : acks, idempotence et batching
Configurez acks, enable.idempotence, batch.size et linger.ms pour un producteur Kafka afin d'éviter les pertes de message, les doublons, tout en atteignant un débit élevé.
Outbox pattern avec Kafka : ne jamais perdre d'événements lors de l'écriture en base
Écrire en base de données et envoyer à Kafka simultanément risque fortement de perdre des événements. Cet article explique comment implémenter le Outbox pattern avec Spring Boot 3 et Kafka pour toujours maintenir la cohérence.
Saga pattern avec Kafka : transactions distribuées et réservation
Implémentez le Saga pattern en orchestration avec Spring Boot et Kafka. Réservez vols, hôtels, paiement avec compensation automatique en cas d'échec.
Schema Registry et Avro/Protobuf dans Kafka avec Spring Boot
Utilisez Confluent Schema Registry avec Avro et Protobuf dans Spring Boot 3 pour contrôler le format des messages Kafka et faire évoluer le schéma de manière sûre.
Surveillance de Kafka : consumer lag et métriques à surveiller
Qu'est-ce que le consumer lag, comment le mesurer via CLI, AdminClient et Micrometer, les métriques broker/producer/consumer à surveiller et comment configurer des alertes pertinentes.
Consumer group et rebalance dans Kafka : pourquoi le consumer s'arrête
Comment fonctionne le rebalance, pourquoi il arrête le consumer et comment le minimiser avec la configuration du poll, le rebalance coopératif et l'adhésion statique.
Partition key dans Kafka : ordre des messages et répartition de charge
Comment Kafka choisit la partition à partir de la clé, comment choisir la clé pour conserver l'ordre des messages sans créer de partition chaude, et les erreurs courantes avec Spring Boot.
Retry et dead letter topic avec Spring Kafka
Configurer retry blocking et non-blocking pour les consumers Kafka dans Spring Boot 3, envoyer les messages d'erreur vers un dead letter topic et écrire des tests de vérification.
Producer Kafka : acs, retry et idempotence correctement
Découvrez comment acs, retries et idempotence travaillent ensemble pour garantir que les messages ne sont pas perdus ou en doublons lorsque le producer envoie des données à Kafka.
Kafka basique : Topic, Partition et Offset
Explication des trois concepts fondamentaux de Kafka — topic, partition, offset — avec des exemples producer/consumer en Spring Boot.