kafka python向所有使用者发布

ojsjcaue  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(498)

有没有办法将消息发布到所有分区?我使用的是kafka python==1.4.3。
从文件中了解到
键(可选)–与消息关联的键。可用于确定将消息发送到哪个分区。如果partition为none(并且producer的partitioner config保留为默认值),那么具有相同密钥的消息将被传递到相同的分区(但是如果key为none,则随机选择分区)。必须是bytes类型,或者可以通过配置的密钥序列化程序序列化为bytes。
但无法找到消息是否可以发布到所有分区的任何线索。

yqyhoc1h

yqyhoc1h1#

我们知道没有直接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.

相关问题