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.
Inheritance
System.Object
CommittedOffsets
Inherited Members
System.Object.ToString()
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
Namespace: Confluent.Kafka
Assembly: cs.temp.dll.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 |
---|---|---|
System.Collections.Generic.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 |
---|---|
System.Collections.Generic.IList<TopicPartitionOffsetError> |