Блог

Есть ли способ создать ключ раздела на основе хэша, вычисляемого по атрибуту полезной нагрузки с использованием Spring Boot. Существует интерфейс, вызываемый Partition в apache-kafka, но не уверен, как распределить сообщения по разным разделам с помощью Spring boot.

Смотрите документацию kafka.

Задайте partitioner.class свойству producer имя вашего класса.

partitioner.class

Класс разделителя, который реализует org.apache.kafka.clients.producer.Partitioner interface .

По умолчанию: org.apache.kafka.clients.producer.internals.DefaultPartitioner