Modifier and Type | Field and Description |
---|---|
static TypeArg<KafkaProducerRecord> |
__TYPE_ARG |
TypeArg<K> |
__typeArg_0 |
TypeArg<V> |
__typeArg_1 |
Constructor and Description |
---|
KafkaProducerRecord(KafkaProducerRecord delegate) |
KafkaProducerRecord(KafkaProducerRecord delegate,
TypeArg<K> typeArg_0,
TypeArg<V> typeArg_1) |
Modifier and Type | Method and Description |
---|---|
static <K,V> KafkaProducerRecord<K,V> |
create(String topic,
K key,
V value)
Create a concrete instance of a Vert.x producer record
|
static <K,V> KafkaProducerRecord<K,V> |
create(String topic,
K key,
V value,
Long timestamp,
Integer partition)
Create a concrete instance of a Vert.x producer record
|
static <K,V> KafkaProducerRecord<K,V> |
create(String topic,
V value)
Create a concrete instance of a Vert.x producer record
|
KafkaProducerRecord |
getDelegate() |
K |
key() |
static <K,V> KafkaProducerRecord<K,V> |
newInstance(KafkaProducerRecord arg) |
static <K,V> KafkaProducerRecord<K,V> |
newInstance(KafkaProducerRecord arg,
TypeArg<K> __typeArg_K,
TypeArg<V> __typeArg_V) |
Integer |
partition() |
Long |
timestamp() |
String |
topic() |
V |
value() |
public static final TypeArg<KafkaProducerRecord> __TYPE_ARG
public KafkaProducerRecord(KafkaProducerRecord delegate)
public KafkaProducerRecord(KafkaProducerRecord delegate, TypeArg<K> typeArg_0, TypeArg<V> typeArg_1)
public KafkaProducerRecord getDelegate()
public static <K,V> KafkaProducerRecord<K,V> create(String topic, K key, V value, Long timestamp, Integer partition)
topic
- the topic this record is being sent tokey
- the key (or null if no key is specified)value
- the valuetimestamp
- the timestamp of this recordpartition
- the partition to which the record will be sent (or null if no partition was specified)public static <K,V> KafkaProducerRecord<K,V> create(String topic, K key, V value)
topic
- the topic this record is being sent tokey
- the key (or null if no key is specified)value
- the valuepublic static <K,V> KafkaProducerRecord<K,V> create(String topic, V value)
topic
- the topic this record is being sent tovalue
- the valuepublic String topic()
public K key()
public V value()
public Long timestamp()
public Integer partition()
public static <K,V> KafkaProducerRecord<K,V> newInstance(KafkaProducerRecord arg)
public static <K,V> KafkaProducerRecord<K,V> newInstance(KafkaProducerRecord arg, TypeArg<K> __typeArg_K, TypeArg<V> __typeArg_V)
Copyright © 2017. All rights reserved.