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).
تنفيذ مستهلكي Kafka الآمنين من النوع لاستهلاك الأحداث من خلال إلغاء تسلسل msgspec. يُستخدم عند إنشاء عملاء غير متزامنين يقومون بمعالجة أحداث المجال (رسائل الطلب، والمعاملات) مع إدارة الإزاحة، واسترداد الأخطاء، وإيقاف التشغيل بسلاسة، والتتبع الموزع. يتعامل مع تكوين المستهلك والالتزامات اليدوية واستراتيجيات إعادة التوازن. المصدر: dawiddutoit/custom-claude.