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

    Type Alias Partitioner

    Partitioner: (
        topic: string,
        key: Uint8Array | null,
        partitionCount: number,
    ) => number

    Partitioner function.

    Determines which partition a message should be sent to.

    Type Declaration

      • (topic: string, key: Uint8Array | null, partitionCount: number): number
      • Parameters

        • topic: string

          The topic name.

        • key: Uint8Array | null

          The message key, or null.

        • partitionCount: number

          Total number of partitions for the topic.

        Returns number

        The partition index to send to.