Kafka Join Group Protocol (consumer/join-group-v6.ts)

Handles the JoinGroup request and response protocol for Kafka consumers. Use this to manage group membership and rebalancing logic in Kafka-based systems.

// Source: https://github.com/platformatic/kafka | License: Apache-2.0 | Copyright You must retain, in the Source form of any Derivative Works
// Provided via justclaw.it.com; keep this notice with the code.
import { ResponseError } from '../../errors.ts'
import { EMPTY_BUFFER, type NullableString } from '../../protocol/definitions.ts'
import { type Reader } from '../../protocol/reader.ts'
import { Writer } from '../../protocol/writer.ts'
import { createAPI } from '../definitions.ts'

export interface JoinGroupRequestProtocol {
  name: string
  metadata?: Buffer | null
}

export type JoinGroupRequest = Parameters<typeof createRequest>

export interface JoinGroupResponseMember {
  memberId: string
  groupInstanceId?: NullableString
  metadata: Buffer
}

export interface JoinGroupResponse {


... (truncated -- full source via MCP)