Example on how to use Headers with Confluent Kafka C# library

Question

I am trying to use Headers with the Confluent Kafka C# API but the Message<> template does not have a Headers parameter. How do you pass in headers to the ProduceAsync method?

Answer 1

var header = new Headers();
    
    
header.Add(“key”, Encoding.UTF8.GetBytes(“value”)) ;
    

var config = new ProducerConfig
{
    BootstrapServers = "localhost:9092",
};

var _producer = new ProducerBuilder<Null, string>(config).Build();
var stringMessage = "Your message";

await _producer.ProduceAsync(topic, new Message<Null, string> { Key = null, Value = stringMessage, Headers = header });