Message Queue Patterns
Implements robust asynchronous communication and event-driven architectures using Kafka, RabbitMQ, Redis, and Postgres.
This skill provides specialized guidance for designing and implementing distributed messaging systems within Claude Code. It offers production-ready patterns for a variety of message brokers, including Kafka for high-throughput streaming, RabbitMQ for complex routing, Redis Streams for lightweight pub/sub, and Postgres for simpler queueing needs. By leveraging unified APIs like FastStream and low-level drivers like aiokafka and aio-pika, developers can build decoupled, scalable microservices with reliable delivery guarantees, dead-letter handling, and optimal retry logic.
주요 기능
01Production-grade producer and consumer implementations with proper acknowledgments
02Multi-broker support for Kafka, RabbitMQ, Redis Streams, and Postgres
03Integration with FastStream for unified API and Pydantic validation
04Reliable messaging patterns including dead-letter queues and retries
0569 GitHub stars
06Decision framework for choosing brokers based on throughput and persistence
사용 사례
01Building high-throughput event streaming pipelines for real-time data processing
02Implementing background task distribution and work queues for resource-intensive jobs
03Decoupling microservices to improve system scalability and fault tolerance