Sample project for Apache Flink with Streaming Engine and JDBC Sink
[[Source(Protobuf)] -> [Sink(Kafka)]]
|
|
[Kafka]
|
|
[[Source (Kafka) -> Map(Protobuf, Row) -> Sink(JDBC)]]
Sample project for Apache Flink with Streaming Engine and JDBC Sink
Java