Namespace Silverback.Messaging.Consuming.KafkaOffsetStore

Stores the latest consumed offsets in EntityFramework.

Stores the latest consumed offsets in memory.

Creates the KafkaOffsetStoreScope and ensures that the offsets are being stored to the client side offset store (if configured).

Builds an IKafkaOffsetStore instance according to the provided KafkaOffsetStoreSettings.

The scope of the client side offset store. A scope is created per each consume cycle and is used to atomically store the processed offsets.

Adds the storage-specific methods to the KafkaOffsetStoreScope.

Stores the latest consumed offsets in PostgreSql.

Adds the Kafka offset store specific methods to the ISilverbackContext.

Represents a Kafka offset stored in the database.

Stores the latest consumed offsets in Sqlite.

The client side offset store.

Builds an IKafkaOffsetStore instance according to the provided KafkaOffsetStoreSettings.