Sharing here some code samples I have created for Flink with Pulsar as a source, due to my personal interest on Pulsar + Flink, that hopefully other people might find useful. https://github.com/streamnative/pulsar-flink-patterns For those interesting in unified batch and streaming architectures and maybe want to get a better understanding on WHY pulsar + flink, here is a good from the previous Pulsar Summit. Although more cool stuff will be in place in the upcoming Pulsar Summit in 10 days - If anyone is interested in learning more. Flink experts from Immerok, Decodable and Ververica will be there 😄