Skip to main content

Interactive Priority Queue Explorer

See priority-based routing in action! Use the interactive explorer below to step through 4 stages of priority queue implementation. Watch as messages are progressively routed to appropriate queues based on severity, customer tier, and multi-criteria scoring.

How to Use This Explorer​

  1. Navigate using arrow keys (← →) or click the numbered stage buttons
  2. Compare the Input (left) and Output (right) JSON at each stage
  3. Observe how messages are routed (different colors for each priority queue)
  4. Inspect the YAML code showing exactly what switch configuration was added
  5. Learn from the stage description explaining the technique and performance benefit

Interactive Priority Queue Explorer​

Original Input

All messages flow through a single processing path regardless of importance. Critical alerts compete with routine logs, causing latency spikes and SLA violations.

Use ← → arrow keys to navigate
📥Input
{
"timestamp": "2024-01-15T14:30:00Z",
"severity": "CRITICAL",
"event_type": "payment.failed",
"customer_tier": "enterprise",
"urgency": "high",
"service": "payment-service",
"message": "Payment processing failed",
"amount": 50000
}
📤Output
{
"timestamp": "2024-01-15T14:30:00Z",
"severity": "CRITICAL",
"event_type": "payment.failed",
"customer_tier": "enterprise",
"urgency": "high",
"service": "payment-service",
"message": "Payment processing failed",
"amount": 50000,
"processed_at": "2024-01-15T14:30:01Z"
}
Added/Changed
Removed
Completed Step
Current Step
Not Done Yet
📄New Pipeline Stepinput.yaml
# No priority routing - all messages treated equally
output:
  kafka:
    addresses: ["kafka-broker-1:9092","kafka-broker-2:9092"]
    topic: all-events
    batching:
      count: 100      # Same batching for all
      period: 30s     # Same delay for all
    max_retries: 3    # Same reliability for all

Try It Yourself​

Ready to build this priority queue system? Follow the step-by-step tutorial:

Deep Dive into Each Step​

Want to understand each transformation in depth?

Next: Set up your environment to build this priority queue system yourself