kafka-consumer-implementation

Features and purpose

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 management, error recovery, graceful shutdown, and distributed tracing. Handles consumer configuration, manual commits, and rebalancing strategies.

Quick start

Follow the repository instructions for this skill and your agent. Review the files and dependencies before adding it to your workflow.