Namespace Silverback.Messaging.Consuming.KafkaOffsetStore
Classes
- EntityFrameworkKafkaOffsetStore
Stores the latest consumed offsets in EntityFramework.
- InMemoryKafkaOffsetStore
Stores the latest consumed offsets in memory.
- InMemoryKafkaOffsetStoreSettings
The InMemoryKafkaOffsetStore settings.
- KafkaOffsetStoreConsumerBehavior
Creates the KafkaOffsetStoreScope and ensures that the offsets are being stored to the client side offset store (if configured).
- KafkaOffsetStoreFactory
Builds an IKafkaOffsetStore instance according to the provided KafkaOffsetStoreSettings.
- KafkaOffsetStoreScope
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.
- KafkaOffsetStoreScopeRelationalExtensions
Adds the storage-specific methods to the KafkaOffsetStoreScope.
- KafkaOffsetStoreSettings
The IKafkaOffsetStore settings.
- PostgreSqlKafkaOffsetStore
Stores the latest consumed offsets in PostgreSql.
- PostgreSqlKafkaOffsetStoreSettings
The PostgreSqlKafkaOffsetStore settings.
- SilverbackContextKafkaOffsetStoreExtensions
Adds the Kafka offset store specific methods to the ISilverbackContext.
- SilverbackStoredOffset
Represents a Kafka offset stored in the database.
- SqliteKafkaOffsetStore
Stores the latest consumed offsets in Sqlite.
- SqliteKafkaOffsetStoreSettings
The SqliteKafkaOffsetStore settings.
Interfaces
- IKafkaOffsetStore
The client side offset store.
- IKafkaOffsetStoreFactory
Builds an IKafkaOffsetStore instance according to the provided KafkaOffsetStoreSettings.