Sources

Data sources provide Joule with the required data to execute use cases. Fractalworks has provided a number of ready to use implementations to enable you to start building use cases

---

Available source implementations

Events consumed are deserialised in to StreamEvents ready for pipeline processing either automatically or through a custom transformer implementation.

Streaming

Kafka

Kafka consumer transport ingests data from subscribed cluster topics.

Rabbit MQ

RabbitMQ is lightweight and easy to deploy messaging platform.

MQTT

Joule provides the ability to subscribe to events using MQTT source consumer

Web

Rest

RESTful consumer endpoints designed to facilitate seamless integration

File

Minio S3

MinIO file consumer using S3 object level access to cloud or local hosted buckets

File Watcher

Process large event files using stream processing