Package io.vertx.mutiny.kafka.client.consumer

Class KafkaConsumerRecord<K,V>

java.lang.Object

io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<K,V>

public class KafkaConsumerRecord<K,V>
extends Object

Vert.x Kafka consumer record

NOTE: This class has been automatically generated from the original non Mutiny-ified interface using Vert.x codegen.

Field Summary

Fields

Modifier and Type	Field	Description
static TypeArg<KafkaConsumerRecord>	__TYPE_ARG
TypeArg<K>	__typeArg_0
TypeArg<V>	__typeArg_1

Constructor Summary

Constructors

Constructor	Description
KafkaConsumerRecord(io.vertx.kafka.client.consumer.KafkaConsumerRecord delegate)
KafkaConsumerRecord(io.vertx.kafka.client.consumer.KafkaConsumerRecord delegate, TypeArg<K> typeArg_0, TypeArg<V> typeArg_1)
KafkaConsumerRecord(Object delegate, TypeArg<K> typeArg_0, TypeArg<V> typeArg_1)

Method Summary

Modifier and Type	Method	Description
long	checksum()	Deprecated. As of Kafka 0.11.0.
boolean	equals(Object o)
io.vertx.kafka.client.consumer.KafkaConsumerRecord	getDelegate()
int	hashCode()
List<KafkaHeader>	headers()
K	key()
static <K,V> KafkaConsumerRecord<K,V>	newInstance(io.vertx.kafka.client.consumer.KafkaConsumerRecord arg)
static <K,V> KafkaConsumerRecord<K,V>	newInstance(io.vertx.kafka.client.consumer.KafkaConsumerRecord arg, TypeArg<K> __typeArg_K, TypeArg<V> __typeArg_V)
long	offset()
int	partition()
long	timestamp()
org.apache.kafka.common.record.TimestampType	timestampType()
String	topic()
String	toString()
V	value()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

__TYPE_ARG

public static final TypeArg<KafkaConsumerRecord> __TYPE_ARG

__typeArg_0

public final TypeArg<K> __typeArg_0

__typeArg_1

public final TypeArg<V> __typeArg_1

Constructor Detail

KafkaConsumerRecord

public KafkaConsumerRecord(io.vertx.kafka.client.consumer.KafkaConsumerRecord delegate)

KafkaConsumerRecord

public KafkaConsumerRecord(Object delegate,
                           TypeArg<K> typeArg_0,
                           TypeArg<V> typeArg_1)

KafkaConsumerRecord

public KafkaConsumerRecord(io.vertx.kafka.client.consumer.KafkaConsumerRecord delegate,
                           TypeArg<K> typeArg_0,
                           TypeArg<V> typeArg_1)

Method Detail

getDelegate

public io.vertx.kafka.client.consumer.KafkaConsumerRecord getDelegate()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

topic

public String topic()

Returns:

the topic this record is received from

partition

public int partition()

Returns:

the partition from which this record is received

offset

public long offset()

Returns:

the position of this record in the corresponding Kafka partition.

timestamp

public long timestamp()

Returns:

the timestamp of this record

timestampType

public org.apache.kafka.common.record.TimestampType timestampType()

Returns:

the timestamp type of this record

checksum

@Deprecated
public long checksum()

Deprecated.

As of Kafka 0.11.0. Because of the potential for message format conversion on the broker, the checksum returned by the broker may not match what was computed by the producer. It is therefore unsafe to depend on this checksum for end-to-end delivery guarantees. Additionally, message format v2 does not include a record-level checksum (for performance, the record checksum was replaced with a batch checksum). To maintain compatibility, a partial checksum computed from the record timestamp, serialized key size, and serialized value size is returned instead, but this should not be depended on for end-to-end reliability.

Returns:

the checksum (CRC32) of the record.

key

public K key()

Returns:

the key (or null if no key is specified)

value

public V value()

Returns:

the value

headers

public List<KafkaHeader> headers()

Returns:

the list of consumer record headers

newInstance

public static <K,V> KafkaConsumerRecord<K,V> newInstance(io.vertx.kafka.client.consumer.KafkaConsumerRecord arg)

newInstance

public static <K,V> KafkaConsumerRecord<K,V> newInstance(io.vertx.kafka.client.consumer.KafkaConsumerRecord arg,
                                                                     TypeArg<K> __typeArg_K,
                                                                     TypeArg<V> __typeArg_V)