Examples for end-to-end exactly-once

Read from Kafka, write to JDBC

This application shows exactly-once output to JDBC through transactions:

Application

Test

Read from Kafka, write to Files

This application shows exactly-once output to HDFS through atomic file operation:

Application

Test