Implements request creation and response parsing for the Kafka JoinGroup API version 5 protocol. Reuse when building Kafka client libraries or brokers.
// 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)
See the full source, get the GitHub permalink, and search for more like it.
Get a free API key