kafka-python向所有消费者发布

Question

是否有向所有分区发布消息的方法？我使用的是kafka-python==1.4.3。

从文件中了解到

键(可选)-一个与消息相关联的键。可用于确定要向哪个分区发送消息。如果分区为None (并且生产者的分区配置被保留为默认值)，那么具有相同键的消息将被传递到同一个分区(但如果键为None，则随机选择分区)。必须是类型字节，或者可以通过配置的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.