Брокеры Kafka ожидают, что в качестве ключей и значений сообщений задействуются байтовые массивы.
Диаграммы Софи Бли-Голдман (Sophie Blee-Goldman) из ее статьи в блоге за май 2020 года «От жаждущего к умному в перебалансировках Apache Kafka» (https://oreil.ly/fZzac).
Другое решение было описано Джесси Андерсоном (Jesse Anderson) в его блоге в статье «У Kafka появился абсолютно новый Poll» (https://oreil.ly/zN6ek).
Другой подход заключается в том, чтобы один потребитель заполнял очередь событий, а несколько рабочих потоков выполняли работу из нее. Пример можно увидеть в статье в блоге Игоря Бузатовича (Igor Buzatoviс́) (https://oreil.ly/uMzj1).