Skip to content

HashRingBasedPartitionedStreamQueueMapper Methods

Queue mapper that tracks which partition was mapped to which QueueId