Azure Service Bus reader for Flink 2

From Lair Of Sorrow
Revision as of 08:03, 17 December 2025 by Miki (talk | contribs) (Created page with "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://flink.apache.org/2023/05/03/howto-create-a-batch-source-with-the-new-source-framework/ - but for older Flink version Category:In English Category:Programming")
(diff) ← Older revision | Latest revision (diff) | Newer revision → (diff)

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