Кафка-питон публикуется для всех потребителей

Question

Есть ли способ опубликовать сообщение для всех разделов?Я использую kafka-python == 1.4.3.

Из документации понятно, что ключ

(необязательно) - ключ, ассоциируемый с сообщением.Может использоваться, чтобы определить, в какой раздел отправить сообщение.Если для раздела установлено значение «Нет» (а конфигурация разделителя производителя оставлена ​​по умолчанию), то сообщения с одинаковым ключом будут доставляться в тот же раздел (но если для ключа установлено значение «Нет», раздел выбирается случайным образом).Должен быть байтами типа или быть сериализуемым в байты через настроенный key_serializer.

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

Answer 1

Понял, что прямого API нет, но этого можно достичь, объединив два вызова.

partitions_for(topic) - Returns set of all known partitions for the topic.

send(topic, value=None, key=None, headers=None, partition=None, timestamp_ms=None) - Publish a message to a topic.