Interface IKafkaOffsetCommittedCallback
Declares the OnOffsetsCommitted(CommittedOffsets, KafkaConsumer) event handler.
Namespace: Silverback.Messaging.Broker.Callbacks
Assembly: Silverback.Integration.Kafka.dll
Syntax
public interface IKafkaOffsetCommittedCallback : IBrokerCallbackMethods
| Improve this doc View sourceOnOffsetsCommitted(CommittedOffsets, KafkaConsumer)
Called to report the result of offset commits.
Declaration
void OnOffsetsCommitted(CommittedOffsets offsets, KafkaConsumer consumer)Parameters
| Type | Name | Description |
|---|---|---|
| CommittedOffsets | offsets | The per-partition offsets and success or error information and the overall operation success or error information. |
| KafkaConsumer | consumer | The related consumer instance. |
Remarks
Possible error conditions:
-
Entire request failed:
Erroris set, but not per-partition errors. -
All partitions failed:
Erroris set to the value of the last failed partition, but each partition may have different errors. -
Some partitions failed: global
Erroris success (Confluent.Kafka.ErrorCode.NoError).