我刚见过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。
1条答案
按热度按时间qnzebej01#
看起来您正在返回一个发送请求的结果。
尝试在循环中生成消息,而不是重新启动应用程序,从而重新启动循环分区