conduktor.io ↗

Kafka AlterShareGroupOffsets Changelog — Protocol Version History

What is AlterShareGroupOffsets?

Resets or advances a share group's start offset for specific partitions, the equivalent of kafka-consumer-groups.sh --reset-offsets for share groups. Use this to skip over poison-pill records causing repeated delivery failures across all members.

VersionKafkaChanges
AlterShareGroupOffsetsRequest
v04.1
+ GroupId string
+ Topics []AlterShareGroupOffsetsRequestTopic
+ TopicName string
+ Partitions []AlterShareGroupOffsetsRequestPartition
+ PartitionIndex int32
+ StartOffset int64
~ Flexible encoding enabled FLEXIBLE
AlterShareGroupOffsetsResponse
v04.1
+ ThrottleTimeMs int32
+ ErrorCode int16
+ ErrorMessage string
+ Responses []AlterShareGroupOffsetsResponseTopic
+ TopicName string
+ TopicId uuid
+ Partitions []AlterShareGroupOffsetsResponsePartition
+ PartitionIndex int32
+ ErrorCode int16
+ ErrorMessage string
~ Flexible encoding enabled FLEXIBLE