关于如何在融合的Kafka C#库中使用头的示例

using Confluent.Kafka;

var config = new ProducerConfig
{
    BootstrapServers = "kafka-broker1:9092,kafka-broker2:9092",
    // 其他配置项...
};

using (var producer = new ProducerBuilder<Null, string>(config).Build())
{
    var message = new Message<Null, string>
    {
        Value = "Hello Kafka!",
        Headers = new Headers
        {
            new Header("header-key1", Encoding.UTF8.GetBytes("header-value1")),
            new Header("header-key2", Encoding.UTF8.GetBytes("header-value2"))
        }
    };

    producer.Produce("topic-name", message);
}

using Confluent.Kafka;

var config = new ConsumerConfig
{
    BootstrapServers = "kafka-broker1:9092,kafka-broker2:9092",
    GroupId = "consumer-group",
    // 其他配置项...
};

using (var consumer = new ConsumerBuilder<Ignore, string>(config).Build())
{
    consumer.Subscribe("topic-name");

    while (true)
    {
        var consumeResult = consumer.Consume();

        Console.WriteLine($"Received message: {consumeResult.Message.Value}");

        foreach (var header in consumeResult.Message.Headers)
        {
            Console.WriteLine($"Header: {header.Key} = {Encoding.UTF8.GetString(header.GetValueBytes())}");
        }
    }
}