0

最近の 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を使用すると、すべてのメッセージが配信されます。すべてのメッセージを待たずに配信する方法。(私は単一のパーティションを持っています)

4

1 に答える 1