Azure Service Bus reader for Flink 2

From Lair Of Sorrow

This article documents the process of me figuring out how to read from a custom source in Flink 2, in particular - from a service bus hosted on Azure.

Requirements

  • infinite source reading from a service bus topic
  • connection kept open while the job is running

Learning material