kafka-consumer-implementation

Implement production-grade Kafka consumers that reliably consume and process domain events with high performance, type safety, and comprehensive error recovery. Covers msgspec deserialization, confluent-kafka configuration, offset management, OpenTelemetry tracing, and anti-corruption layer patterns for translating message schemas to domain models.

Use when building event-driven systems that consume domain events from Kafka topics with "implement Kafka consumer", "consume events from Kafka", "process order messages", or "set up event consumer".

Do NOT use when mocking Kafka consumers in unit tests (use pytest-adapter-integration-testing), implementing producers (use kafka-producer-implementation), or testing with testcontainers (use kafka-integration-testing).

透過 msgspec 反序列化實現類型安全的 Kafka 消費者以進行事件消費。 在建構處理域事件（訂單訊息、交易）的非同步消費者時使用 具有偏移管理、錯誤恢復、正常關閉和分散式追蹤。 處理消費者配置、手動提交和重新平衡策略。 來源：dawiddutoit/custom-claude。