expanso-priority-queues

Route incoming events to Kafka topics based on calculated priority scores.

1|Updated Feb 1, 2026
One-click install
npx skills add https://github.com/expanso-io/expanso-skills --skill expanso-priority-queues
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: expanso-priority-queues
Source: https://github.com/expanso-io/expanso-skills/tree/main/skills/recipes/priority-queues
Command: npx skills add https://github.com/expanso-io/expanso-skills --skill expanso-priority-queues

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes scripts (resource) components.

What problem does it solve?

This Skill automates the routing of incoming messages to different queues based on their calculated priority, ensuring critical events are processed first.

Core Features & Use Cases

  • Dynamic Priority Scoring: Calculates a priority score based on severity, customer tier, and event type.
  • Age-Based Boost: Implements an anti-starvation mechanism by boosting the priority of older messages.
  • Configurable Routing: Directs messages to different Kafka topics (critical, high, normal, low) based on their final priority score.
  • Use Case: In a system monitoring service, this skill can ensure that critical alerts from enterprise customers are immediately routed to a high-priority processing queue, while less urgent informational messages are batched for later processing.

Quick Start

Run the priority queues pipeline with sample data.

Frequently Asked Questions about expanso-priority-queues

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

FAQPage Schema
How do I route Kafka messages to different topics based on priority?

Route Kafka messages by calculating a priority score from event severity, customer tier, and event type, then dynamically directing events to critical, high, normal, or low priority queues based on that score.

How does priority routing handle event starvation for older messages?

Priority routing prevents starvation by applying an age-based boost mechanism that automatically increases the priority score of older events, ensuring they eventually process despite continuous incoming high-priority traffic.

Can I prioritize event processing based on customer tier and severity?

Yes, you can prioritize event processing by analyzing both customer tier and event severity to calculate a dynamic priority score, ensuring critical alerts from enterprise customers route immediately to high-priority processing queues.

What is the best way to separate critical alerts from normal events in a data pipeline?

The best way to separate critical alerts is dynamic message routing, which scores events and splits them across multiple Kafka topics so critical alerts process immediately while less urgent informational messages batch for later processing.

Does this priority queue routing require any specific Kafka dependencies?

No specific external dependencies are required for priority queue routing, as the provided scripts operate independently to calculate scores and route incoming events directly to your configured Kafka topics.