Write production-grade integration tests for Kafka producers and consumers using testcontainers. Covers setting up temporary test brokers, testing producer/consumer workflows, verifying message ordering guarantees, testing error scenarios, and validating delivery semantics without mocking external services.
Use when testing Kafka producer/consumer workflows end-to-end with "test Kafka integration", "verify message ordering", "test Kafka roundtrip", or "validate exactly-once semantics".
Do NOT use for unit testing with mocked Kafka (use pytest-adapter-integration-testing), implementing producers/consumers (use respective kafka--implementation skills), or schema validation (use kafka-schema-management).
Écrivez des tests d'intégration pour les producteurs et les consommateurs Kafka à l'aide de conteneurs de tests. À utiliser pour tester les flux de travail producteur/consommateur, vérifier l'ordre des messages, tester scénarios d'erreur et validation de la sémantique exactement une fois. Crée des courtiers Kafka de test et valide le comportement de streaming de bout en bout sans se moquer. Source : dawiddutoit/custom-claude.