Implementation of ZeroMQ source and sink for Apache Flink™ and usage example.
Application receives serialized data from some source (financial market trades). Data serialized/deserialized by protocol buffers' generated object - TradeOuterClass wrapped into ZMQSourceSchema class.
SocketTradesCount - example usage.
"Apache®, Apache Flink™, Flink™, and the squirrel logo are either registered trademarks or trademarks of the Apache Software Foundation in the United States and/or other countries."