kafka consumerrecord数据结构是怎样的

发布时间:2025-04-07 02:05:45

阅读量:279

Kafka的ConsumerRecord是消费者从Kafka主题中读取消息时返回的一个数据结构。它包含了消费消息所需的各种信息，例如消息键（key）、消息值（value）、分区号（partition）、偏移量（offset）以及消息的时间戳（timestamp）等。

以下是ConsumerRecord的主要字段及其含义：

topic：消息所属的主题名称。partition：消息所在的分区编号。offset：消费者在该分区中读取到的消息的偏移量。key：消息的键，用于消费者根据键进行消息的过滤或分组。键可以是null，如果生产者没有设置键。value：消息的值，是生产者在发送消息时附上的数据。值也可以是null，如果生产者没有设置值。timestamp：消息的时间戳，表示消息被发送的时间。这个时间戳不是递增的，而是根据Kafka服务器的配置可以配置为递增或时间戳类型。timestampType：时间戳的类型，可以是TIMESTAMP_TYPE_LOG_APPEND_TIME（基于日志条目时间的递增时间戳）或TIMESTAMP_TYPE_CREATE_TIME（基于消息创建时间的递增时间戳）。headers：消息的头部信息，包含了一系列的键值对，用于传递额外的信息。

ConsumerRecord的具体结构如下（以Java为例）：

public class ConsumerRecord {
    private final String topic;
    private final int partition;
    private final long offset;
    private final K key;
    private final V value;
    private final long timestamp;
    private final TimestampType timestampType;
    private final Mapbyte[]> headers;
    // 构造函数、getter和setter方法省略...
}