View Source KafkaEx.Protocol.Kayrock.OffsetCommit (kafka_ex v1.0.0-rc.1)
This module handles Offset Commit request & response parsing. Request is built using Kayrock protocol, response is parsed to native KafkaEx structs.
The OffsetCommit API commits consumer group offsets to Kafka. It supports multiple versions:
- v0: Basic commit to Zookeeper
- v1: Adds timestamp, generation_id, member_id (Kafka/ZK storage)
- v2: Removes timestamp, adds retention_time (Kafka storage, recommended)
- v3: Includes throttle time
- v4: Same as V3 (pure version bump)
- v5: Removes retention_time_ms from request
- v6: Adds committed_leader_epoch per partition
- v7: Adds group_instance_id for static membership (KIP-345)
- v8: Flexible version with compact encodings + tagged_fields (KIP-482)