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)