Adds Event Hubs Streaming Aspire Support #9328
Draft
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Adds support for Event Hubs Streaming for Orleans clusters hosted via Aspire for #9244
This PR is marked as Draft due to the upcoming changes to support passing non-connection string properties via Aspire, in this case Hub and Consumer Group.
Related Pull Request: https://github.com/dotnet/aspire/pull/7468/files
This PR will be updated to use the new functionality once released.
Passing Hub and Consumer Group
The Hub and Consumer Group currently need to be created and passed as environment variables.
To create the Hub and Consumer Group please see this related issue (dotnet/aspire#5561) and gist (https://gist.github.com/oising/3dd68b7605cae511434ced4971b6551a)
To pass the configuration, please use the following environment variables, where
[name]
is the ServiceKey (name) of the Event Hubs resource.Table Checkpointer
Feedback is requested on how to best handle passing Azure Table Checkpointer. Currently, two configuration values are supported similar to that of Hub and Consumer Group
If the Connection String is supplied, then it is used. If the Connection Name is passed without a Connection String, then it is used to look up a Connection String. This requires adding a matching keyed Table service client.
Microsoft Reviewers: Open in CodeFlow