Implement type-safe Kafka consumers for event consumption with msgspec deserialization. Use when building async consumers that process domain events (order messages, transactions) with offset manageme
skills/kafka-consumer-implementation/SKILL.md(main)