-
Notifications
You must be signed in to change notification settings - Fork 5.1k
Open
Labels
ClientThis issue is related to a non-management packageThis issue is related to a non-management packageEvent Hubscustomer-reportedIssues that are reported by GitHub users external to the Azure organization.Issues that are reported by GitHub users external to the Azure organization.issue-addressedWorkflow: The Azure SDK team believes it to be addressed and ready to close.Workflow: The Azure SDK team believes it to be addressed and ready to close.questionThe issue doesn't require a change to the product in order to be resolved. Most issues start as thatThe issue doesn't require a change to the product in order to be resolved. Most issues start as that
Description
Library name
Azure.Messaging.EventHubs.Consumer
Please describe the feature.
We distribute transactions on one Event Hub, and dimensions (like Accounts) on another compacted Event Hub.
Every consumer of Accounts needs the full, up-to-date snapshot from all partitions.
Currently, each consumer must have its own consumer group to read from partitions, which adds unnecessary complexity and maintenance (dynamic consumer-group creation, cleanup, etc.).
It would be much simpler if we could start reading from a specific partition and offset without needing a consumer group, similar to Confluent.Kafka’s
API.
using var consumer = new ConsumerBuilder<Ignore, string>(config)
.SetValueDeserializer(Deserializers.Utf8)
.SetErrorHandler((_, e) => Console.WriteLine($"Error: {e.Reason}"))
.Build();
consumer.Assign(new TopicPartitionOffset(topic, 0, Offset.End));
Metadata
Metadata
Assignees
Labels
ClientThis issue is related to a non-management packageThis issue is related to a non-management packageEvent Hubscustomer-reportedIssues that are reported by GitHub users external to the Azure organization.Issues that are reported by GitHub users external to the Azure organization.issue-addressedWorkflow: The Azure SDK team believes it to be addressed and ready to close.Workflow: The Azure SDK team believes it to be addressed and ready to close.questionThe issue doesn't require a change to the product in order to be resolved. Most issues start as thatThe issue doesn't require a change to the product in order to be resolved. Most issues start as that