@qualithm/kafka-client - v0.1.6
    Preparing search index...

    Type Alias JoinGroupRequest

    JoinGroup request payload.

    type JoinGroupRequest = {
        groupId: string;
        groupInstanceId?: string | null;
        memberId: string;
        protocols: readonly JoinGroupProtocol[];
        protocolType: string;
        reason?: string | null;
        rebalanceTimeoutMs?: number;
        sessionTimeoutMs: number;
        taggedFields?: readonly TaggedField[];
    }
    Index

    Properties

    groupId groupInstanceId? memberId protocols protocolType reason? rebalanceTimeoutMs? sessionTimeoutMs taggedFields?

    Properties

    groupId: string

    The group ID to join.

    groupInstanceId?: string | null

    The group instance ID for static membership (v5+). Null if not static.

    memberId: string

    The member ID. Empty string for first join; assigned ID for subsequent joins.

    protocols: readonly JoinGroupProtocol[]

    Supported protocols with metadata.

    protocolType: string

    Protocol type (e.g. "consumer").

    reason?: string | null

    Reason for joining (v8+).

    rebalanceTimeoutMs?: number

    The rebalance timeout in milliseconds (v1+). Defaults to sessionTimeoutMs if not set.

    sessionTimeoutMs: number

    The session timeout in milliseconds.

    taggedFields?: readonly TaggedField[]

    Tagged fields (v6+).

    Settings

    Member Visibility

    On This Page

    Properties