kafka-producer-implementation

Implement production-grade Kafka producers that reliably publish domain events with high performance, type safety, and comprehensive error handling. Covers msgspec serialization, confluent-kafka configuration, OpenTelemetry tracing, and anti-corruption layer patterns for translating domain models to message schemas.

Use when building event publishers that send domain events to Kafka topics with "implement Kafka producer", "publish events to Kafka", "send order events", or "create event publisher".

Do NOT use for consuming events (use kafka-consumer-implementation), testing with testcontainers (use kafka-integration-testing), or designing schemas (use kafka-schema-management).

通过 msgspec 序列化实现类型安全的 Kafka 生产者以进行事件流处理。 在构建发布域事件（订单、交易等）的异步/等待生产者时使用 具有模式验证、错误处理、重试逻辑和分布式跟踪。 处理生产者配置、幂等写入和正常关闭。 来源：dawiddutoit/custom-claude。