обработку данных для каждого отдельного партишена независимо от других?
Confluet-kafka-go, к сожалению, обрабатывает все доставшиеся клиенту партишены разом.
А какой кейс требует такой реализации?
Когда закидываем в топик таски на обработку, партиционируя их по ключам сущностей(последовательность обработки для каждой сущности критична). И в случае если одна из партиций окажется перегружена , или обработка тасок в ней замедлится, таски из других партиций обрабатывались максимально своевременно
Обсуждают сегодня