Class SqliteKafkaOffsetStore

Namespace

Silverback.Messaging.Consuming.KafkaOffsetStore

Assembly

Silverback.Storage.Sqlite.dll

Stores the latest consumed offsets in Sqlite.

public class SqliteKafkaOffsetStore : IKafkaOffsetStore

Inheritance

object

SqliteKafkaOffsetStore

Implements

IKafkaOffsetStore

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

SqliteKafkaOffsetStore(SqliteKafkaOffsetStoreSettings)

Initializes a new instance of the SqliteKafkaOffsetStore class.

public SqliteKafkaOffsetStore(SqliteKafkaOffsetStoreSettings settings)

Parameters

settings SqliteKafkaOffsetStoreSettings

The offset store settings.

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.