Кафка Шаблон для отправки записей

Question

Мы использовали Spring Kafka 2.1 в наших проектах. Существует вариант использования для отправки сообщения всем разделам в теме, чтобы все потребители могли идентифицировать событие. Есть способ использовать kafkaTemplate для отправки одной записи ввсе разделы темы кафки?.

Answer 1

Архитектура Partitioner имеет следующую структуру:

/**
 * Compute the partition for the given record.
 *
 * @param topic The topic name
 * @param key The key to partition on (or null if no key)
 * @param keyBytes The serialized key to partition on( or null if no key)
 * @param value The value to partition on or null
 * @param valueBytes The serialized value to partition on or null
 * @param cluster The current cluster metadata
 */
public int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster);

Итак, как вы видите, не существует готового способа определения нескольких разделов одновременно.

Я могу только предложить отправку одного и того же сообщения всем разделам вручную в цикле.

То, что вы спрашиваете, только из архитектуры Apache Kafka.