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
- https://nightlies.apache.org/flink/flink-docs-release-2.3/docs/dev/datastream/sources/ official flink docs
- https://flink.apache.org/2023/05/03/howto-create-a-batch-source-with-the-new-source-framework/ - but for older Flink version
