Minimal working example of protobuf models streamed from kafka into a flink pipeline.
serialization kafka protobuf cep deserialization stream-processing event-driven flink example-repo kafkaconnector
-
Updated
Feb 7, 2020 - Java