public static void Main(string[] args)
        {
            //地址及端口号
            var conf = new ProducerConfig { BootstrapServers = "localhost:9092" };

            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())
            {
                //for (int i = 0; i < 100; ++i)
                //{
                
                    p.Produce("test", new Message<Null, string> { Value = "messagehowsf"}, handler);//kafka协议数据发送

                //}

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