最近の c# プロジェクトで Confluent kafka パッケージを使用しています。次の方法でプロデューサーを作成しました。
prodConfig = new ProducerConfig { BootstrapServers = "xxx.xxx.xxx.xxx:xxx"};
foreach(msg in msglist){
using(var producer = new ProducerBuilder<Null, string>(prodConfig).Build()){
producer.ProduceAsync(topic, new Message<Null, string> {Value = msg});
}
}
しかし問題は、私のメッセージの一部が消費者に届いていないことです。彼らはどこかで迷子になっています。ただし、プロデューサーでawaitを使用すると、すべてのメッセージが配信されます。すべてのメッセージを待たずに配信する方法。(私は単一のパーティションを持っています)