Package org.apache.kafka.clients.consumer

Class ConsumerRecord<K,​V>

java.lang.Object
org.apache.kafka.clients.consumer.ConsumerRecord<K,​V>
public class ConsumerRecord<K,​V>
extends Object
A key/value pair to be received from Kafka. This also consists of a topic name and a partition number from which the record is being received, an offset that points to the record in a Kafka partition, and a timestamp as marked by the corresponding ProducerRecord.

  • Field Summary

    Fields
    Modifier and Type Field Description
    static long NO_TIMESTAMP  
    static int NULL_CHECKSUM
    Deprecated.
    checksums are no longer exposed by this class, this constant will be removed in Apache Kafka 4.0 (deprecated since 3.0).
    static int NULL_SIZE  

  • Constructor Summary

    Constructors
    Constructor Description
    ConsumerRecord​(String topic, int partition, long offset, long timestamp, org.apache.kafka.common.record.TimestampType timestampType, int serializedKeySize, int serializedValueSize, K key, V value, Headers headers, Optional<Integer> leaderEpoch)
    Creates a record to be received from a specified topic and partition
    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)
    Deprecated.
    use one of the constructors without a `checksum` parameter.
    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, Headers headers)
    Deprecated.
    use one of the constructors without a `checksum` parameter.
    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, Headers headers, Optional<Integer> leaderEpoch)
    Deprecated.
    use one of the constructors without a `checksum` parameter.
    ConsumerRecord​(String topic, int partition, long offset, K key, V value)
    Creates a record to be received from a specified topic and partition (provided for compatibility with Kafka 0.9 before the message format supported timestamps and before serialized metadata were exposed).

  • Method Summary

    Modifier and Type Method Description
    Headers headers()
    The headers (never null)
    K key()
    The key (or null if no key is specified)
    Optional<Integer> leaderEpoch()
    Get the leader epoch for the record if available
    long offset()
    The position of this record in the corresponding Kafka partition.
    int partition()
    The partition from which this record is received
    int serializedKeySize()
    The size of the serialized, uncompressed key in bytes.
    int serializedValueSize()
    The size of the serialized, uncompressed value in bytes.
    long timestamp()
    The timestamp of this record
    org.apache.kafka.common.record.TimestampType timestampType()
    The timestamp type of this record
    String topic()
    The topic this record is received from (never null)
    String toString()  
    V value()
    The value

    Methods inherited from class java.lang.Object

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

  • Field Details

    • NO_TIMESTAMP

      public static final long NO_TIMESTAMP
      See Also:
      Constant Field Values

    • NULL_SIZE

      public static final int NULL_SIZE
      See Also:
      Constant Field Values

    • NULL_CHECKSUM

      @Deprecated public static final int NULL_CHECKSUM
      Deprecated.
      checksums are no longer exposed by this class, this constant will be removed in Apache Kafka 4.0 (deprecated since 3.0).
      See Also:
      Constant Field Values

  • Constructor Details

    • ConsumerRecord

      public ConsumerRecord​(String topic, int partition, long offset, K key, V value)
      Creates a record to be received from a specified topic and partition (provided for compatibility with Kafka 0.9 before the message format supported timestamps and before serialized metadata were exposed).
      Parameters:
      topic - The topic this record is received from
      partition - The partition of the topic this record is received from
      offset - The offset of this record in the corresponding Kafka partition
      key - The key of the record, if one exists (null is allowed)
      value - The record contents

    • ConsumerRecord

      public ConsumerRecord​(String topic, int partition, long offset, long timestamp, org.apache.kafka.common.record.TimestampType timestampType, int serializedKeySize, int serializedValueSize, K key, V value, Headers headers, Optional<Integer> leaderEpoch)
      Creates a record to be received from a specified topic and partition
      Parameters:
      topic - The topic this record is received from
      partition - The partition of the topic this record is received from
      offset - The offset of this record in the corresponding Kafka partition
      timestamp - The timestamp of the record.
      timestampType - The timestamp type
      serializedKeySize - The length of the serialized key
      serializedValueSize - The length of the serialized value
      key - The key of the record, if one exists (null is allowed)
      value - The record contents
      headers - The headers of the record
      leaderEpoch - Optional leader epoch of the record (may be empty for legacy record formats)

    • ConsumerRecord

      @Deprecated public 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)
      Deprecated.
      use one of the constructors without a `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).
      Creates a record to be received from a specified topic and partition (provided for compatibility with Kafka 0.10 before the message format supported headers).
      Parameters:
      topic - The topic this record is received from
      partition - The partition of the topic this record is received from
      offset - The offset of this record in the corresponding Kafka partition
      timestamp - The timestamp of the record.
      timestampType - The timestamp type
      serializedKeySize - The length of the serialized key
      serializedValueSize - The length of the serialized value
      key - The key of the record, if one exists (null is allowed)
      value - The record contents

    • ConsumerRecord

      @Deprecated public 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, Headers headers)
      Deprecated.
      use one of the constructors without a `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).
      Creates a record to be received from a specified topic and partition
      Parameters:
      topic - The topic this record is received from
      partition - The partition of the topic this record is received from
      offset - The offset of this record in the corresponding Kafka partition
      timestamp - The timestamp of the record.
      timestampType - The timestamp type
      serializedKeySize - The length of the serialized key
      serializedValueSize - The length of the serialized value
      key - The key of the record, if one exists (null is allowed)
      value - The record contents
      headers - The headers of the record.

    • ConsumerRecord

      @Deprecated public 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, Headers headers, Optional<Integer> leaderEpoch)
      Deprecated.
      use one of the constructors without a `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).
      Creates a record to be received from a specified topic and partition
      Parameters:
      topic - The topic this record is received from
      partition - The partition of the topic this record is received from
      offset - The offset of this record in the corresponding Kafka partition
      timestamp - The timestamp of the record.
      timestampType - The timestamp type
      serializedKeySize - The length of the serialized key
      serializedValueSize - The length of the serialized value
      key - The key of the record, if one exists (null is allowed)
      value - The record contents
      headers - The headers of the record
      leaderEpoch - Optional leader epoch of the record (may be empty for legacy record formats)

  • Method Details

    • topic

      public String topic()
      The topic this record is received from (never null)

    • partition

      public int partition()
      The partition from which this record is received

    • headers

      public Headers headers()
      The headers (never null)

    • key

      public K key()
      The key (or null if no key is specified)

    • value

      public V value()
      The value

    • offset

      public long offset()
      The position of this record in the corresponding Kafka partition.

    • timestamp

      public long timestamp()
      The timestamp of this record

    • timestampType

      public org.apache.kafka.common.record.TimestampType timestampType()
      The timestamp type of this record

    • serializedKeySize

      public int serializedKeySize()
      The size of the serialized, uncompressed key in bytes. If key is null, the returned size is -1.

    • serializedValueSize

      public int serializedValueSize()
      The size of the serialized, uncompressed value in bytes. If value is null, the returned size is -1.

    • leaderEpoch

      public Optional<Integer> leaderEpoch()
      Get the leader epoch for the record if available
      Returns:
      the leader epoch or empty for legacy record formats

    • toString

      public String toString()
      Overrides:
      toString in class Object