Class KafkaOffsetStoreFactory

Builds an IKafkaOffsetStore instance according to the provided KafkaOffsetStoreSettings.

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()

Namespace: Silverback.Messaging.Consuming.KafkaOffsetStore

Assembly: Silverback.Integration.Kafka.dll

Syntax

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

Constructors

KafkaOffsetStoreFactory()

Builds an IKafkaOffsetStore instance according to the provided KafkaOffsetStoreSettings.

Declaration

public KafkaOffsetStoreFactory()

Methods

GetStore(KafkaOffsetStoreSettings, IServiceProvider)

Returns an IKafkaOffsetStore according to the specified settings.

Declaration

public IKafkaOffsetStore GetStore(KafkaOffsetStoreSettings settings, IServiceProvider serviceProvider)

Parameters

Type	Name	Description
KafkaOffsetStoreSettings	settings	The settings that will be used to create the IKafkaOffsetStore.
IServiceProvider	serviceProvider	The IServiceProvider that can be used to resolve additional services.

Returns

Type	Description
IKafkaOffsetStore	The IKafkaOffsetStore.

Implements

IKafkaOffsetStoreFactory