SOURCES.md

Sources

Cron

A cron source creates a message containing the cron schedule time with a layout.

Example

Database

Periodically queries a database for messages.

HTTP

Exposes a HTTP service.

Example

Kafka

Consumes messages from a Kafka topic.

Example

NATS Streaming (STAN)

Consumes messages from a NATS streaming subject.

Example

NATS JetStream

Consumers message from a NATS JetStream subject

Example

Volume

Periodically queries a volume for files to process.

• Storage Volumes e.g. NFS, Azure File, Config Map, Secret
• Container Storage Interface (CSI) Drivers e.g. AWS EBS, Google Cloud Storage
• S3 (not production ready)