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).
Напишите интеграционные тесты для производителей и потребителей Kafka, используя тест-контейнеры. Используйте при тестировании рабочих процессов производителя/потребителя, проверке порядка сообщений, тестировании сценарии ошибок и проверка семантики «точно один раз». Создает тестовые брокеры Kafka. и проверяет поведение сквозной потоковой передачи без насмешек. Источник: dawiddutoit/custom-claude.