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。