The use-cases of real time data analytics needs a real-time data processing service. Khodza is a real time stream aggregator built on top of Apache Flink. Currently Khodza accepts these data sources:
- Apache Kafka
- Elasticsearch 6+
Khodza sinks its aggregation results into these outputs:
- Apache Kafka
- InfluxDB
- Elasticsearch 6+
Environment Properties: Global example
environment.properties
Job specific examplesscele.namespace.properties.example
presentronik.properties.example
To compile:
mvn clean package
To run:
<target execution class> <target job properties>
for example:
org.datastream.khodza.job.Scele scele.s1.properties