Inputs
Inputs define where data enters your pipeline. Select an input type when creating a flow in the UI.
| Component | Description |
|---|---|
| Generate | Generates messages on a schedule — for testing or recurring job triggers |
| HTTP Client | Pulls data via HTTP requests |
| HTTP Server | Accepts incoming HTTP requests (webhooks) |
| Kafka | Consumes messages from Kafka topics |
| AMQP 0.9 | Consumes messages from an AMQP 0.9 queue (e.g. RabbitMQ) |
| Broker | Combines multiple inputs into one flow |
| CDC MySQL | CDC from MySQL/MariaDB binlog |
| MCP Tool | Exposes a flow as a tool for AI assistants via MCP |
| Shopify | Fetches data from Shopify stores |