TsgcWSPClient_Kafka › Methods › CommitOffset

CommitOffset Method

Commits a specific offset for a topic/partition in the consumer group.

Syntax

procedure CommitOffset(const aTopic: string; aPartition: Integer; aOffset: Int64);

Parameters

• aTopic: the name of the topic whose offset is committed.
• aPartition: the partition whose offset is committed.
• aOffset: the offset value to commit for the consumer group.

Remarks

Commits an explicit offset for a single topic and partition in the current consumer group. Use this method when you manage offsets manually and want full control over the position from which the group resumes, rather than committing the last consumed offsets with CommitSync. The committed value is the offset of the next record to read.

Example

oKafka.CommitOffset('my-topic', 0, 42);

Back to Methods