We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
In https://github.com/dapr/dotnet-sdk/blob/master/src/Dapr.Client/DaprClientGrpc.cs#L214, the entry metadata is always empty which prevents us to set the sessionId when publishing events to a session enabled topic.
An option would be to add an overload which takes a list of entries as parameter.
The text was updated successfully, but these errors were encountered:
@mapaille - Are you asking for an override that sets the same metadata per event? Or an override that lets you specify metadata per event?
Sorry, something went wrong.
@halspang I would like an override that lets me specify metadata per event because each event in a batch can have its own session id.
@halspang Here is the source code on how to add a service bus message with a session id to a service bus message batch.
https://github.com/Azure/azure-sdk-for-net/blob/c3897ec79c796bcd681dbe3fe525bd1153da8548/sdk/servicebus/Azure.Messaging.ServiceBus/src/Sender/ServiceBusMessageBatch.cs#L110
https://github.com/Azure/azure-sdk-for-net/blob/c3897ec79c796bcd681dbe3fe525bd1153da8548/sdk/servicebus/Azure.Messaging.ServiceBus/src/Primitives/ServiceBusMessage.cs#L256
Makes sense to me, I think this could be a valuable addition.
@halspang Kafka seems to have similar feature using the key metadata. https://developer.confluent.io/courses/apache-kafka/partitions/
key
No branches or pull requests
In https://github.com/dapr/dotnet-sdk/blob/master/src/Dapr.Client/DaprClientGrpc.cs#L214, the entry metadata is always empty which prevents us to set the sessionId when publishing events to a session enabled topic.
An option would be to add an overload which takes a list of entries as parameter.
The text was updated successfully, but these errors were encountered: