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