Class KafkaOffsetStoreFactory

Namespace

Silverback.Messaging.Consuming.KafkaOffsetStore

Assembly

Silverback.Integration.Kafka.dll

Builds an IKafkaOffsetStore instance according to the provided KafkaOffsetStoreSettings.

public class KafkaOffsetStoreFactory : ExtensibleFactory<IKafkaOffsetStore, KafkaOffsetStoreSettings>, IKafkaOffsetStoreFactory

Inheritance

object

ExtensibleFactory<IKafkaOffsetStore, KafkaOffsetStoreSettings>

KafkaOffsetStoreFactory

Implements

IKafkaOffsetStoreFactory

Inherited Members

ExtensibleFactory<IKafkaOffsetStore, KafkaOffsetStoreSettings>.AddFactory<TSettings>(Func<TSettings, IServiceProvider, IKafkaOffsetStore>)

ExtensibleFactory<IKafkaOffsetStore, KafkaOffsetStoreSettings>.HasFactory<TSettings>()

ExtensibleFactory<IKafkaOffsetStore, KafkaOffsetStoreSettings>.OverrideFactories(Func<KafkaOffsetStoreSettings, IServiceProvider, IKafkaOffsetStore>)

ExtensibleFactory<IKafkaOffsetStore, KafkaOffsetStoreSettings>.GetService<TSettings>(TSettings, IServiceProvider)

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

KafkaOffsetStoreFactory()

public KafkaOffsetStoreFactory()

Methods

GetStore(KafkaOffsetStoreSettings, IServiceProvider)

Returns an IKafkaOffsetStore according to the specified settings.

public IKafkaOffsetStore GetStore(KafkaOffsetStoreSettings settings, IServiceProvider serviceProvider)

Parameters

settings KafkaOffsetStoreSettings

The settings that will be used to create the IKafkaOffsetStore.

serviceProvider IServiceProvider

The IServiceProvider that can be used to resolve additional services.

Returns

IKafkaOffsetStore

The IKafkaOffsetStore.