Class EntityFrameworkKafkaOffsetStore

Namespace

Silverback.Messaging.Consuming.KafkaOffsetStore

Assembly

Silverback.Storage.EntityFramework.dll

Stores the latest consumed offsets in EntityFramework.

public class EntityFrameworkKafkaOffsetStore : IKafkaOffsetStore

Inheritance

object

EntityFrameworkKafkaOffsetStore

Implements

IKafkaOffsetStore

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

EntityFrameworkKafkaOffsetStore(EntityFrameworkKafkaOffsetStoreSettings, IServiceScopeFactory)

Initializes a new instance of the EntityFrameworkKafkaOffsetStore class.

public EntityFrameworkKafkaOffsetStore(EntityFrameworkKafkaOffsetStoreSettings settings, IServiceScopeFactory serviceScopeFactory)

Parameters

settings EntityFrameworkKafkaOffsetStoreSettings

The offset store settings.

serviceScopeFactory IServiceScopeFactory

The IServiceScopeFactory.

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.