org.apache.kafka.clients.consumer

Class ConsumerRecord<K,V>

java.lang.Object

org.apache.kafka.clients.consumer.ConsumerRecord<K,V>

public final class ConsumerRecord<K,V>
extends java.lang.Object

A key/value pair to be received from Kafka. This consists of a topic name and a partition number, from which the record is being received and an offset that points to the record in a Kafka partition.

Constructor Summary

Constructors

Constructor and Description
ConsumerRecord(java.lang.String topic, int partition, long offset, K key, V value) Creates a record to be received from a specified topic and partition

Method Summary

Methods

Modifier and Type	Method and Description
K	key() The key (or null if no key is specified)
long	offset() The position of this record in the corresponding Kafka partition.
int	partition() The partition from which this record is received
java.lang.String	topic() The topic this record is received from
java.lang.String	toString()
V	value() The value

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRecord

public ConsumerRecord(java.lang.String topic,
              int partition,
              long offset,
              K key,
              V value)

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

key - The key of the record, if one exists (null is allowed)

value - The record contents

Method Detail

topic

public java.lang.String topic()

The topic this record is received from

partition

public int partition()

The partition from which this record is received

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.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object