Azure Service Bus reader for Flink 2: Difference between revisions
From Lair Of Sorrow
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" |
mNo edit summary |
||
| Line 8: | Line 8: | ||
== Learning material == | == 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 | * 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:In English]] | ||
[[Category:Programming]] | [[Category:Programming]] | ||
Latest revision as of 19:40, 23 December 2025
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
