kafka-storage

s3-stream-factory

kda-flink-efo-consumer-example

A small example of Flink Job to be released as Kinesis Data Analytics application. In scala. Using protobuf serdes.