Implement production-grade Kafka producers that reliably publish domain events with high performance, type safety, and comprehensive error handling. Covers msgspec serialization, confluent-kafka configuration, OpenTelemetry tracing, and anti-corruption layer patterns for translating domain models to message schemas.
Use when building event publishers that send domain events to Kafka topics with "implement Kafka producer", "publish events to Kafka", "send order events", or "create event publisher".
Do NOT use for consuming events (use kafka-consumer-implementation), testing with testcontainers (use kafka-integration-testing), or designing schemas (use kafka-schema-management).
Implémentez des producteurs Kafka de type sécurisé pour le streaming d'événements avec la sérialisation msgspec. À utiliser lors de la création de producteurs asynchrones/d'attente qui publient des événements de domaine (commandes, transactions, etc.) avec validation de schéma, gestion des erreurs, logique de nouvelle tentative et traçage distribué. Gère la configuration du producteur, les écritures idempotentes et l'arrêt progressif. Source : dawiddutoit/custom-claude.