Skip to content

[FEATURE REQ] Support reading from a specific partition/offset without a consumer group (Kafka-style Assign) #53669

@AJosephsen

Description

@AJosephsen

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 packageEvent Hubscustomer-reportedIssues 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.questionThe issue doesn't require a change to the product in order to be resolved. Most issues start as that

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions