Interface IKafkaOffsetStore

Namespace

Silverback.Messaging.Consuming.KafkaOffsetStore

Assembly

Silverback.Integration.Kafka.dll

The client side offset store.

public interface IKafkaOffsetStore

Methods

GetStoredOffsets(string)

Returns the stored offsets for the specified consumer group.

IReadOnlyCollection<KafkaOffset> GetStoredOffsets(string groupId)

Parameters

groupId string

The consumer group id.

Returns

IReadOnlyCollection<KafkaOffset>

The collection of KafkaOffset that have been stored.

StoreOffsetsAsync(string, IEnumerable<KafkaOffset>, ISilverbackContext?)

Stores the specified offsets.

Task StoreOffsetsAsync(string groupId, IEnumerable<KafkaOffset> offsets, ISilverbackContext? context = null)

Parameters

groupId string

The consumer group id.

offsets IEnumerable<KafkaOffset>

The offsets.

context ISilverbackContext

The ISilverbackContext.

Returns

Task

A Task representing the asynchronous operation.