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

    Type Alias PartitionAssignor

    Partition assignor strategy.

    Receives all member subscriptions and known partition counts, and produces a partition assignment for each member.

    type PartitionAssignor = {
        assign: (
            members: readonly MemberSubscription[],
            partitionCounts: ReadonlyMap<string, number>,
        ) => readonly MemberAssignment[];
        name: string;
    }
    Index

    Properties

    assign name

    Properties

    assign: (
        members: readonly MemberSubscription[],
        partitionCounts: ReadonlyMap<string, number>,
    ) => readonly MemberAssignment[]

    Assign partitions to members.

    Type Declaration

      • (
            members: readonly MemberSubscription[],
            partitionCounts: ReadonlyMap<string, number>,
        ): readonly MemberAssignment[]

      • Parameters

        • members: readonly MemberSubscription[]

          Subscriptions for all group members.

        • partitionCounts: ReadonlyMap<string, number>

          Known partition counts per topic. May be empty if partition counts are not yet discovered.

        Returns readonly MemberAssignment[]

        Assignment for each member.

    name: string

    Protocol name sent in JoinGroup metadata (e.g. "range", "roundrobin", "cooperative-sticky").

    Settings

    Member Visibility

    On This Page

    Properties