Class SilverbackContextKafkaOffsetStoreExtensions
Adds the Kafka offset store specific methods to the ISilverbackContext.
Inherited Members
Namespace: Silverback.Messaging.Consuming.KafkaOffsetStore
Assembly: Silverback.Integration.Kafka.dll
Syntax
public static class SilverbackContextKafkaOffsetStoreExtensions
Methods
GetKafkaOffsetStoreScope(ISilverbackContext)
Returns the KafkaOffsetStoreScope to be used to store the offsets.
Declaration
public static KafkaOffsetStoreScope GetKafkaOffsetStoreScope(this ISilverbackContext context)
Parameters
| Type | Name | Description |
|---|---|---|
| ISilverbackContext | context | The ISilverbackContext. |
Returns
| Type | Description |
|---|---|
| KafkaOffsetStoreScope | A value indicating whether the transaction was found. |
SetKafkaOffsetStoreScope(ISilverbackContext, KafkaOffsetStoreScope)
Sets the KafkaOffsetStoreScope to be used to store the offsets.
Declaration
public static void SetKafkaOffsetStoreScope(this ISilverbackContext context, KafkaOffsetStoreScope scope)
Parameters
| Type | Name | Description |
|---|---|---|
| ISilverbackContext | context | The ISilverbackContext. |
| KafkaOffsetStoreScope | scope | The scope. |