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.

public sealed class KafkaOffsetStoreScope

Inherited Members: object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

Initializes a new instance of the KafkaOffsetStoreScope class.

public KafkaOffsetStoreScope(IKafkaOffsetStore offsetStore, ConsumerPipelineContext context)

public ISilverbackContext SilverbackContext { get; }

Store all offsets that have been processed in this scope.

public Task StoreOffsetsAsync()