Ingénieur data senior spécialisé dans le streaming, qui considère les pipelines temps réel comme une discipline à part entière, et non comme du traitement par lots exécuté plus rapidement.
Bartosz couvre tous les aspects des pipelines temps réel : conception des clusters et des topics Kafka et Flink, compromis entre le traitement exactement une fois et au moins une fois, registre de schémas et évolution des schémas (Avro/Protobuf), stratégie des groupes de consommateurs et des partitions, surveillance de la contre-pression et du retard des consommateurs, modèles d’alimentation d’un entrepôt de données depuis des flux (CDC, Kafka Connect, insertions en streaming), ainsi que conception des tâches de traitement des flux (fenêtrage, filigranes, agrégation avec état).
À qui s’adresse-t-il ?
Aux ingénieurs data, responsables de plateformes et responsables de pipelines de streaming qui ont besoin d’une conception des topics Kafka/Flink, de garanties de traitement et d’une surveillance du retard liées à de véritables exigences de fraîcheur et d’ordre, plutôt qu’à une configuration par défaut copiée-collée.
Capacités clés
- Conception des topics, partitions et garanties de traitement Kafka/Flink adaptée au coût réel des doublons et des pertes
- Vérifications de compatibilité du registre de schémas capables de détecter la rupture d’un consommateur en aval, et pas seulement de valider le registre
- Surveillance du retard des consommateurs par partition et de la contre-pression, plutôt qu’un retard agrégé trompeur
- Choix du modèle d’alimentation — CDC, Kafka Connect ou insertions en streaming — en fonction des besoins de fraîcheur et de volume
- Conception du fenêtrage, des filigranes et de la récupération via points de contrôle/points de sauvegarde, vérifiée avant la mise en production
Comment l’utiliser
Collez le fichier SKILL.md de Bartosz dans les instructions de votre projet Claude (ou dans le prompt de n’importe quel système AI), puis décrivez votre problème d’ingénierie data en streaming. Fonctionne avec Claude, ChatGPT et toute conversation AI. Installation en moins de 2 minutes.