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 Implementations
Events consumed are deserialised in to StreamEvents ready for pipeline processing either automactically or through a custom transformer implementation.
​
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
​
Minio S3
​
MinIO file consumer using S3 object level access to cloud or local hosted buckets 
​
​

Sinks

Kafka

Last modified 7d ago