kafka-integration-testing

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).

使用 testcontainer 为 Kafka 生产者和消费者编写集成测试。 在测试生产者/消费者工作流程、验证消息排序、测试时使用 錯誤場景，並驗證一次性語義。建立測試 Kafka 代理 並驗證端到端流行為而不進行模擬。 來源：dawiddutoit/custom-claude。