Используя тему и ключ сообщения, Кафка назначает раздел темы на основе:
... Utils.Murmur2(bytes) % numPartitions ....
Теперь достаточно просто найти код murmur2. Тем не менее, murmur2 нуждается в семени, которое может изменить ход для запуска.
Мой вопрос: дали ключ, например, последовательность байтов, как я могу вычислить, на какой раздел Kafka отправил бы сообщение с теми же байтами ключа? Предположим последовательное разбиение.
Вооружившись этой информацией, я могу предварительно кэшировать некоторую информацию в разных слушателях разделов по мере отскока приложения.