View Source KafkaEx.Protocol.Kayrock.LeaveGroup (kafka_ex v1.0.0-rc.1)

This module handles LeaveGroup request & response parsing. Request is built using Kayrock protocol, response is parsed to native KafkaEx structs.

Supported Versions

  • V0: Basic LeaveGroup
    • Request: group_id, member_id
    • Response: error_code
  • V1: Adds throttle_time_ms to response
    • Request: Same as V0
    • Response: +throttle_time_ms
  • V2: No changes vs V1 (pure version bump)
  • V3: Batch leave (KIP-345) -- STRUCTURAL CHANGE
    • Request: -member_id, +members array (each with member_id, group_instance_id)
    • Response: +members array with per-member error_code
  • V4: Flexible version (KIP-482)
    • Request: Compact string encoding, +tagged_fields
    • Response: Compact encoding, +tagged_fields
    • Domain-relevant fields identical to V3

All known versions (V0-V4) have explicit defimpl implementations. An Any fallback is retained for forward compatibility with unknown future Kayrock versions.