Interface IKafkaOffsetCommittedCallback

Namespace

Silverback.Messaging.Broker.Callbacks

Assembly

Silverback.Integration.Kafka.dll

Declares the OnOffsetsCommitted(CommittedOffsets, IKafkaConsumer) event handler.

public interface IKafkaOffsetCommittedCallback : IBrokerClientCallback

Methods

OnOffsetsCommitted(CommittedOffsets, IKafkaConsumer)

Called to report the result of offset commits.

void OnOffsetsCommitted(CommittedOffsets offsets, IKafkaConsumer consumer)

Parameters

offsets CommittedOffsets

The per-partition offsets and success or error information and the overall operation success or error information.

consumer IKafkaConsumer

The related consumer instance.

Remarks

Possible error conditions:

• Entire request failed: Error is set, but not per-partition errors.
• All partitions failed: Error is set to the value of the last failed partition, but each partition may have different errors.
• Some partitions failed: global Error is success (Confluent.Kafka.ErrorCode.NoError).