Class InMemoryKafkaOffsetStore

Namespace

Silverback.Messaging.Consuming.KafkaOffsetStore

Assembly

Silverback.Storage.Memory.dll

Stores the latest consumed offsets in memory.

public class InMemoryKafkaOffsetStore : IKafkaOffsetStore

Inheritance

object

InMemoryKafkaOffsetStore

Implements

IKafkaOffsetStore

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

InMemoryKafkaOffsetStore()

public InMemoryKafkaOffsetStore()

Methods

GetStoredOffsets(string)

Returns the stored offsets for the specified consumer group.

public 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.

public 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.