conduktor.io ↗

Kafka OffsetDelete Changelog — Protocol Version History

What is OffsetDelete?

Clears stored offsets for specific partitions via kafka-consumer-groups.sh --delete-offsets, resetting a group's tracked position. The group must not be actively consuming those partitions, otherwise returns GROUP_SUBSCRIBED_TO_TOPIC.

VersionKafkaChanges
OffsetDeleteRequest
v02.4
+ GroupId string
+ Topics []OffsetDeleteRequestTopic
+ Name string
+ Partitions []OffsetDeleteRequestPartition
+ PartitionIndex int32
OffsetDeleteResponse
v02.4
+ ErrorCode int16
+ ThrottleTimeMs int32
+ Topics []OffsetDeleteResponseTopic
+ Name string
+ Partitions []OffsetDeleteResponsePartition
+ PartitionIndex int32
+ ErrorCode int16