C＃中的Kafka交易范围

Question

试图在MongoDB中持续一些数据，并将几条消息发布到交易中的所有内容。我正在考虑使用dotnet transactionscope，但我看不到如何将其应用于Confluent Kafka软件包。

        var _database = client.GetDatabase(mongoUrl.DatabaseName);

        using(var transactionScope = new TransactionScope());
        {
          var drinkCollections = _database.GetCollection<Drinks>("drinks").AsTransactionCollection();
          var orders = _database.GetCollection<Orders>("orders").AsTransactionCollection();

          _kafkaProducer.ProduceAsync("commands", "orderID", new OrderCommand() { Waiter = "John", Price = 3.35m });

          transactionScope.Complete();
      }

显然，如果生产方法未能发布到Kafka，则应回滚或取消对MongoDB的持久性。

不确定如何实施交易。任何想法都将不胜感激。