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

    Function createCooperativeStickyAssignor

    • Cooperative sticky partition assignor.

      Attempts to preserve existing assignments across rebalances while maintaining even distribution. When partitions must move, only the affected partitions are revoked and reassigned (incremental cooperative rebalancing).

      Previous assignments are tracked across calls to assign(). Create a new instance per consumer to maintain state.

      Returns PartitionAssignor