public final class ConsumerRecord <K，V>
extends Object

• 现场总结

  字段 

  修饰符和类型	领域和描述
  static long	NO_TIMESTAMP
  static int	NULL_CHECKSUM
  static int	NULL_SIZE

• 构造函数摘要

  构造函数 

  构造函数和描述
  ConsumerRecord(String topic, int partition, long offset, K key, V value) 创建从指定主题和分区接收的记录（在消息格式支持的时间戳之前和公开序列化元数据之前提供与Kafka 0.9的兼容性）。
  ConsumerRecord(String topic, int partition, long offset, long timestamp, org.apache.kafka.common.record.TimestampType timestampType, long checksum, int serializedKeySize, int serializedValueSize, K key, V value) 创建从指定主题和分区接收的记录

• 方法摘要

  方法 

  修饰符和类型	方法和描述
  long	checksum() 记录的校验和（CRC32）。
  K	key() 密钥（如果未指定密钥，则为null）
  long	offset() 此记录在相应Kafka分区中的位置。
  int	partition() 从中接收此记录的分区
  int	serializedKeySize() 序列化未压缩密钥的大小（以字节为单位）。
  int	serializedValueSize() 序列化未压缩值的大小（以字节为单位）。
  long	timestamp() 此记录的时间戳
  org.apache.kafka.common.record.TimestampType	timestampType() 此记录的时间戳类型
  String	topic() 收到此记录的主题
  String	toString()
  V	value() 价值

  • 从类java.lang继承的方法。宾语

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

• 现场细节

  • NO_TIMESTAMP

    public static final long NO_TIMESTAMP

    也可以看看：

    常数字段值

  • NULL_SIZE

    public static final int NULL_SIZE

    也可以看看：

    常数字段值

  • NULL_CHECKSUM

    public static final int NULL_CHECKSUM

    也可以看看：

    常数字段值

• 构造函数详细信息

  • ConsumerRecord

    public ConsumerRecord（String  topic，int分区，长偏移，K  键，V  值）

    创建从指定主题和分区接收的记录（在消息格式支持的时间戳之前和公开序列化元数据之前提供与Kafka 0.9的兼容性）。

    参数：

    topic- 收到此记录的主题

    partition- 收到此记录的主题分区

    offset- 此记录在相应Kafka分区中的偏移量

    key- 记录的密钥（如果存在）（允许为null）

    value- 记录内容

  • ConsumerRecord

    public ConsumerRecord（String  topic，int分区，长偏移，很长的时间戳，org.apache.kafka.common.record.TimestampType timestampType，长校验和，int serializedKeySize，int serializedValueSize，K  键，V  值）

    创建从指定主题和分区接收的记录

    参数：

    topic- 收到此记录的主题

    partition- 收到此记录的主题分区

    offset- 此记录在相应Kafka分区中的偏移量

    timestamp- 记录的时间戳。

    timestampType- 时间戳类型

    checksum- 完整记录的校验和（CRC32）

    serializedKeySize- 序列化密钥的长度

    serializedValueSize- 序列化值的长度

    key- 记录的密钥（如果存在）（允许为null）

    value- 记录内容

• 方法细节

  • 话题

    public  String  topic（）

    收到此记录的主题

  • 划分

    public int partition（）

    从中接收此记录的分区

  • 键

    公钥  K  键（）

    密钥（如果未指定密钥，则为null）

  • 值

    公共  V  值（）

    价值

  • 抵消

    公共长偏移量（）

    此记录在相应Kafka分区中的位置。

  • 时间戳

    公共长时间戳（）

    此记录的时间戳

  • timestampType

    public org.apache.kafka.common.record.TimestampType timestampType（）

    此记录的时间戳类型

  • 校验

    公共长校验和（）

    记录的校验和（CRC32）。

  • serializedKeySize

    public int serializedKeySize（）

    序列化未压缩密钥的大小（以字节为单位）。如果key为null，则返回的大小为-1。

  • serializedValueSize

    public int serializedValueSize（）

    序列化未压缩值的大小（以字节为单位）。如果value为null，则返回的大小为-1。

  • public  String  toString（）

    覆盖：

    toString在班上 Object