如何使用空键在不同分区上为同一主题生成消息

vwkv1x7d  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(245)

我刚见过Kafka,对它还不熟悉。因此,在进行设置时,我创建了6个分区[0,1…5],并尝试将带有null键的消息存储到不同的分区。
例如:

var Config = new Dictionary<string, object> {
    { "group.id", "topic1_group" },
    { "bootstrap.servers", "localhost:9092" },
    { "default.topic.config",new Dictionary<string, object> {
                               { "acks", 1}
                            }
    }
};

var producer = new Producer<string, string>(Config, new StringSerializer(Encoding.UTF8), new StringSerializer(Encoding.UTF8));
return await producer.ProduceAsync("topic1", null, "Message1");

但当我尝试运行生产者类代码时,它会存储在同一个分区中。
编辑:

Kafka Response: partition 4, offset 10

现在,第二个问题再次产生了下一条消息-主题1

Kafka Response: partition 4, offset 11

服务器和客户端分别更新到kafka版本0.10.0和0.9.0。

qnzebej0

qnzebej01#

看起来您正在返回一个发送请求的结果。
尝试在循环中生成消息,而不是重新启动应用程序,从而重新启动循环分区

相关问题