Kafka消息的header存储在哪里？

Kafka消息的header存储在消息体中，并且是以键值对的形式存储。我们可以使用Kafka的Java客户端来访问消息头。

以下是一个示例代码，该代码使用Kafka的Java客户端来创建一个消息并设置header：

import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.header.Header;
import org.apache.kafka.common.header.internals.RecordHeader;
import org.apache.kafka.common.serialization.StringSerializer;

import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

public class KafkaProducerDemo {

    public static void main(String[] args) {

        // Set properties for Kafka producer
        Properties properties = new Properties();
        properties.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        properties.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        properties.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

        // Create Kafka producer
        Producer<String, String> producer = new org.apache.kafka.clients.producer.KafkaProducer<>(properties);

        // Create message and add headers
        List<Header> headers = new ArrayList<>();
        headers.add(new RecordHeader("header_key", "header_value".getBytes()));
        ProducerRecord<String, String> producerRecord = new ProducerRecord<>("test_topic", "test_key", "test_value", headers);

        // Send message to Kafka topic
        producer.send(producerRecord);

        // Close Kafka producer
        producer.close();
    }
}

在上面的代码中，我们使用了Kafka的Java客户端来创建一个带有header的消息，并将其发送到名为“test_topic”的Kafka主题中。需要注意的是，header必须是字节数组形式，因此我们必须将header值转换为字节数组，如上面的代码中所示。