Class 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.

Inheritance

object

KafkaOffsetStoreScope

Inherited Members

object.GetType()

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 sealed class KafkaOffsetStoreScope

Constructors

KafkaOffsetStoreScope(IKafkaOffsetStore, ConsumerPipelineContext)

Initializes a new instance of the KafkaOffsetStoreScope class.

Declaration

public KafkaOffsetStoreScope(IKafkaOffsetStore offsetStore, ConsumerPipelineContext context)

Parameters

Type	Name	Description
IKafkaOffsetStore	offsetStore	The IKafkaOffsetStore.
ConsumerPipelineContext	context	The ISilverbackContext.

Properties

SilverbackContext

Gets the ISilverbackContext.

Declaration

public ISilverbackContext SilverbackContext { get; }

Property Value

Type	Description
ISilverbackContext

Methods

StoreOffsetsAsync()

Store all offsets that have been processed in this scope.

Declaration

public Task StoreOffsetsAsync()

Returns

Type	Description
Task	A Task representing the asynchronous operation.