Class SilverbackContextKafkaOffsetStoreExtensions

Namespace

Silverback.Messaging.Consuming.KafkaOffsetStore

Assembly

Silverback.Integration.Kafka.dll

Adds the Kafka offset store specific methods to the ISilverbackContext.

public static class SilverbackContextKafkaOffsetStoreExtensions

Inheritance

object

SilverbackContextKafkaOffsetStoreExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

GetKafkaOffsetStoreScope(ISilverbackContext)

Returns the KafkaOffsetStoreScope to be used to store the offsets.

public static KafkaOffsetStoreScope GetKafkaOffsetStoreScope(this ISilverbackContext context)

Parameters

context ISilverbackContext

The ISilverbackContext.

Returns

KafkaOffsetStoreScope

A value indicating whether the transaction was found.

SetKafkaOffsetStoreScope(ISilverbackContext, KafkaOffsetStoreScope)

Sets the KafkaOffsetStoreScope to be used to store the offsets.

public static void SetKafkaOffsetStoreScope(this ISilverbackContext context, KafkaOffsetStoreScope scope)

Parameters

context ISilverbackContext

The ISilverbackContext.

scope KafkaOffsetStoreScope

The scope.