Class CommittedOffsets
Encapsulates information provided to a Consumer's OnOffsetsCommitted event - per-partition offsets and success/error together with overall success/error of the commit operation.
Inherited Members
Namespace: Confluent.Kafka
Assembly: Confluent.Kafka.dll
Syntax
public class CommittedOffsets
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.
Constructors
CommittedOffsets(IList<TopicPartitionOffsetError>, Error)
Initializes a new instance of CommittedOffsets.
Declaration
public CommittedOffsets(IList<TopicPartitionOffsetError> offsets, Error error)
Parameters
Type | Name | Description |
---|---|---|
IList<TopicPartitionOffsetError> | offsets | per-partition offsets and success/error. |
Error | error | overall operation success/error. |
Properties
Error
Gets the overall operation success/error.
Declaration
public Error Error { get; }
Property Value
Type | Description |
---|---|
Error |
Offsets
Gets the per-partition offsets and success/error.
Declaration
public IList<TopicPartitionOffsetError> Offsets { get; }
Property Value
Type | Description |
---|---|
IList<TopicPartitionOffsetError> |