Class KafkaOffsetStoreConsumerBehavior
Creates the KafkaOffsetStoreScope and ensures that the offsets are being stored to the client side offset store (if configured).
Inherited Members
Namespace: Silverback.Messaging.Consuming.KafkaOffsetStore
Assembly: Silverback.Integration.Kafka.dll
Syntax
public class KafkaOffsetStoreConsumerBehavior : IConsumerBehavior, IBrokerBehavior, ISortedConstructors
KafkaOffsetStoreConsumerBehavior()
Creates the KafkaOffsetStoreScope and ensures that the offsets are being stored to the client side offset store (if configured).
Declaration
public KafkaOffsetStoreConsumerBehavior()Properties
SortIndex
Gets the sort index.
Declaration
public int SortIndex { get; }Property Value
| Type | Description |
|---|---|
| int |
Methods
HandleAsync(ConsumerPipelineContext, ConsumerBehaviorHandler, CancellationToken)
Process, handles or transforms the message being consumed.
Declaration
public ValueTask HandleAsync(ConsumerPipelineContext context, ConsumerBehaviorHandler next, CancellationToken cancellationToken)Parameters
| Type | Name | Description |
|---|---|---|
| ConsumerPipelineContext | context | The context that is passed along the behaviors pipeline. |
| ConsumerBehaviorHandler | next | The next behavior in the pipeline. |
| CancellationToken | cancellationToken | The cancellation token that can be used to cancel the operation. |
Returns
| Type | Description |
|---|---|
| ValueTask | A ValueTask representing the asynchronous operation. |