messaging-streaming

Evaluate messaging patterns for asynchronous distributed system architectures.

42|2|Updated Jun 1, 2026
One-click install
npx skills add https://github.com/proyecto26/system-design-skills --skill messaging-streaming-proyecto26
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: messaging-streaming
Source: https://github.com/proyecto26/system-design-skills/tree/main/skills/messaging-streaming
Command: npx skills add https://github.com/proyecto26/system-design-skills --skill messaging-streaming-proyecto26

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes references (resource) components.

What problem does it solve?

This skill solves the complexity of designing asynchronous systems by providing a structured framework to choose between queues, pub/sub, streams, and durable workflows, preventing common pitfalls like data loss, duplicate processing, and system meltdowns.

Core Features & Use Cases

  • Architectural Decision Support: Guides the selection of the right messaging pattern based on delivery guarantees, ordering requirements, and throughput needs.
  • Failure Mode Analysis: Provides strategies for backpressure, dead-letter queues, and idempotency to ensure system stability under load.
  • Use Case: Use this skill when designing a high-scale event-driven system to determine whether to use a simple work queue for background jobs or a partitioned stream for event sourcing and replayability.

Quick Start

Use the messaging-streaming skill to evaluate the trade-offs between using a message queue versus a durable stream for our new order processing pipeline.

Frequently Asked Questions about messaging-streaming

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I choose between a message queue and a streaming platform for asynchronous distributed systems?

Asynchronous messaging prevents data loss and duplicate processing in distributed systems by decoupling components through queues, pub/sub, or streams. This structured framework ensures system resilience and stability under heavy load.

What is the best way to handle backpressure and dead-letter queues in event-driven architectures?

The best way to handle backpressure and dead-letter queues is by applying failure mode analysis strategies alongside idempotent consumer design patterns. This ensures system stability and prevents meltdowns when processing high-scale asynchronous messages.

When do I need durable streaming instead of pub-sub for an order processing pipeline?

You need durable streaming instead of pub-sub when your order processing pipeline requires event replayability and strict message ordering. Durable streams support partitioned event sourcing, whereas pub/sub is better suited for simple fire-and-forget decoupled messaging.

How do I design idempotent consumers to prevent duplicate processing in distributed systems?

Design idempotent consumers by implementing specific failure mode analysis strategies that safely handle redelivered messages. This prevents duplicate processing and ensures system resilience when your asynchronous messaging architecture retries failed operations.

Does this messaging architecture framework support high-scale event sourcing with partitioned streams?

Yes, this framework supports high-scale event sourcing by guiding the selection of partitioned stream broker technologies. It evaluates throughput needs and delivery guarantees to ensure your asynchronous architecture can handle demanding workloads.