Prefetch ограничивает число неподтвержденных сообщений на канал у consumer. Без лимита брокер отдает все доступные сообщения; при медленной обработке память растет и распределение между воркерами неравномерное. В Go: channel.Qos(prefetchCount, prefetchSize, global). Разумное значение - 1 или несколько, чтобы один consumer не забирал всю очередь. Равномерная загрузка воркеров.
ch.Qos(10, 0, false)