Оптимизация передачи больших данных

Сервис получает сетевой стрим объёмом 2 ГБ, разбивает его по 1 МБ до символа перевода строки и кладёт чанки в очередь. Несколько реплик подписаны на