When should I use Kafka versus RabbitMQ?

Use Kafka for high-throughput event streaming, log aggregation, and replayable event logs. Use RabbitMQ when you need complex routing logic, message priorities, and flexible pub/sub patterns.

How do I handle job status updates on the frontend?

The skill includes patterns for using Server-Sent Events (SSE) to stream job progress from a background worker back to a React frontend component.

What message brokers does this skill support?

The skill provides comprehensive guidance and code examples for Apache Kafka, RabbitMQ, NATS, Redis Streams, Celery, BullMQ, and Temporal.

Does it include patterns for workflow orchestration?

Yes, it specifically covers Temporal for durable execution, allowing you to build complex multi-step sagas that survive service restarts.

How does this skill help with background jobs?

It provides boilerplate and best practices for common task queues like Celery (Python) and BullMQ (Node.js), including retry logic and dead letter queue management.

Message Queue Integration & Patterns

Name: Message Queue Integration & Patterns
Author: ancoleman

byancoleman

•

158

•

Desarrollo de API

Implements asynchronous communication patterns using message brokers and task queues for scalable, event-driven systems.

This skill provides comprehensive guidance for designing and implementing event-driven architectures using industry-standard message brokers and task queues. It assists developers in selecting the right tools—such as Kafka for event streaming, RabbitMQ for complex routing, or Temporal for durable workflows—while providing production-ready implementation patterns. It covers critical distributed systems concepts including idempotency, dead letter queues, event naming conventions, and background job status tracking with frontend integrations.

Características Principales

01Standardized event naming conventions and JSON schema structures

02158 GitHub stars

03Durable workflow orchestration patterns using Temporal Sagas

04Implementation patterns for task queues like Celery (Python) and BullMQ (TypeScript)

05Broker selection decision tree for Kafka, RabbitMQ, NATS, and Redis

06Real-time job status tracking patterns via SSE and React components

Casos de Uso

01Decoupling microservices to improve system resilience and horizontal scalability

02Offloading long-running operations like report generation and image processing to background workers

03Implementing guaranteed delivery and exactly-once processing for financial transactions

What are Skills?·How to Install

Install with 🐟 Skill.Fish

npx skillfish add ancoleman/ai-design-components using-message-queues

For use in Claude.ai and ChatGPT

Download Skill