dotnet txn-producer

Program.cs

using System;
using Confluent.Kafka;

class Program
{
    public static void Main(string[] args)
    {
        var conf = new ProducerConfig { 
            BootstrapServers = "localhost:9092",
            SecurityProtocol = SecurityProtocol.SaslPlaintext,
            SaslMechanism = SaslMechanism.ScramSha256,
            SaslUsername = "admin",
            SaslPassword = "admin-secret",
            TransactionalId = "myproducer"
        };

        Action<DeliveryReport<Null, string>> handler = r =>
            Console.WriteLine(!r.Error.IsError
                ? $"Delivered message to {r.TopicPartitionOffset}"
                : $"Delivery Error: {r.Error.Reason}");

        using (var p = new ProducerBuilder<Null, string>(conf).Build())
        {
            p.InitTransactions(TimeSpan.FromMinutes(10));
            p.BeginTransaction();
            for (int i=0; i<10; ++i)
            {
                p.Produce("test", new Message<Null, string> { Value = i.ToString() }, handler);
            }

            p.CommitTransaction(TimeSpan.FromSeconds(10));
            // wait for up to 10 seconds for any inflight messages to be delivered.
            p.Flush(TimeSpan.FromSeconds(10));
        }
    }
}