Skip to content

Latest commit

 

History

History
16 lines (8 loc) · 592 Bytes

README.md

File metadata and controls

16 lines (8 loc) · 592 Bytes

Stream processing with Kafka,Flink,Calcite

Java example to read from Kafka, mapping stream in to calcite table, query and write to a new topic with Flink.

Usage

Do a mvn clean install -Dmaven.test.skip=true to build the jar.

Use the following arguments to run jar file:

--read-topic --write-topic --bootstrap.servers --group.id

bin/flink run stream-analytics-0.0.1-SNAPSHOT.jar

jar uf target/stream-analytics-0.0.1-SNAPSHOT.jar application.properties query.sql hazelcast-client.xml consumer.properties producer.properties