Нам нужно передать данные из некоторого источника некоторому потребителю. При этом источник отдает данные небольшими пач

go · concurrencyYandex / Яндекс (3й этап)4 кв 2025не решено

Условие

Нам нужно передать данные из некоторого источника некоторому потребителю. При этом источник отдает данные небольшими пачками (~ десятки записей), а потребитель оптимальнее работает с крупными батчами (~тысячи записей). Реальный пример - поставка данных из очередей типа Kafka в базу Clickhouse.

Заготовка

main.go

package main

func main() {
  // TODO
}

Решение

Разбор

---

Источник: Yandex / Яндекс (3й этап) · 4 кв 2025

← Требуется реализовать функцию func Pipe… · Все задачи · Go · (код без описания) →