kafka-python публикует для всех потребителей

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

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

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

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


python-2.7 apache-kafka kafka-python
person Yogeswaran    schedule 08.04.2019    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Понял, что прямого 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.
person Yogeswaran    schedule 08.04.2019