expanso-fan-out-kafka

Distribute incoming data streams to multiple Kafka topics concurrently.

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

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes scripts (resource) and references (resource) components.

What problem does it solve?

This Skill efficiently routes incoming data to multiple Kafka topics simultaneously, enabling parallel processing and distribution across different consumers.

Core Features & Use Cases

  • Multi-Topic Publishing: Send a single data point to several distinct Kafka topics.
  • Dynamic Topic Routing: Configure topics based on data content or predefined patterns.
  • Use Case: Distribute sensor readings to a 'raw-data' topic for archival, a 'real-time-alerts' topic for immediate monitoring, and a 'downstream-processing' topic for further analysis.

Quick Start

Run the fan-out-kafka pipeline with sample data using the provided run script.

Frequently Asked Questions about expanso-fan-out-kafka

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

FAQPage Schema
How do I distribute incoming data streams to multiple Kafka topics simultaneously?

To distribute data streams to multiple Kafka topics simultaneously, you need a fan-out routing mechanism that publishes a single data point to several distinct topics concurrently for parallel processing and real-time distribution across consumers.

What is dynamic topic routing in Kafka and when do I need it?

Dynamic topic routing in Kafka is the process of directing incoming data to specific topics based on data content or predefined patterns. You need it when routing sensor readings to different topics like archival, real-time alerts, or downstream processing pipelines.

Do I need Expanso Edge and Kafka broker credentials to set up data routing?

Yes, you need Expanso Edge running and configured Kafka broker credentials to set up concurrent data routing. These prerequisites enable the pipeline to connect to your broker and dynamically distribute incoming data streams.

How do I configure a fan-out data pipeline for parallel processing consumers?

To configure a fan-out data pipeline for parallel processing, use the provided run script to start routing sample data. This allows a single input data point to be published concurrently to multiple configured Kafka topics for different consumers.

What is the best way to send a single data point to several distinct Kafka topics?

The best way to send a single data point to several distinct Kafka topics is using a multi-topic publishing pattern. This approach allows concurrent parallel processing, such as distributing data to archival, alert, and analytical topics simultaneously.

Can I route data to different Kafka topics based on data content or predefined patterns?

Yes, you can route data to different Kafka topics based on data content or predefined patterns. This dynamic topic selection enables real-time data routing, allowing you to direct specific incoming data streams to the appropriate concurrent processing pipelines.