Сегодня с librdkafka есть два варианта для partition.assignment.strategy librdkafka : диапазон и циклический перебор. Я ищу, если есть способ добавить пользовательскую стратегию назначения.
Bests