Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<KafkaProducerRecord> |
__TYPE_ARG |
io.vertx.lang.rx.TypeArg<K> |
__typeArg_0 |
io.vertx.lang.rx.TypeArg<V> |
__typeArg_1 |
Constructor and Description |
---|
KafkaProducerRecord(KafkaProducerRecord delegate) |
KafkaProducerRecord(Object delegate,
io.vertx.lang.rx.TypeArg<K> typeArg_0,
io.vertx.lang.rx.TypeArg<V> typeArg_1) |
Modifier and Type | Method and Description |
---|---|
KafkaProducerRecord<K,V> |
addHeader(KafkaHeader header)
Add an header to this record.
|
KafkaProducerRecord<K,V> |
addHeader(String key,
Buffer value)
Like
addHeader(java.lang.String, java.lang.String) but with a key/value pair |
KafkaProducerRecord<K,V> |
addHeader(String key,
String value)
Like
addHeader(java.lang.String, java.lang.String) but with a key/value pair |
KafkaProducerRecord<K,V> |
addHeaders(List<KafkaHeader> headers)
Add a list of headers to this record.
|
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
|
boolean |
equals(Object o) |
KafkaProducerRecord |
getDelegate() |
int |
hashCode() |
List<KafkaHeader> |
headers() |
K |
key() |
static <K,V> KafkaProducerRecord<K,V> |
newInstance(KafkaProducerRecord arg) |
static <K,V> KafkaProducerRecord<K,V> |
newInstance(KafkaProducerRecord arg,
io.vertx.lang.rx.TypeArg<K> __typeArg_K,
io.vertx.lang.rx.TypeArg<V> __typeArg_V) |
Integer |
partition() |
Long |
timestamp() |
String |
topic() |
String |
toString() |
V |
value() |
public static final io.vertx.lang.rx.TypeArg<KafkaProducerRecord> __TYPE_ARG
public final io.vertx.lang.rx.TypeArg<K> __typeArg_0
public final io.vertx.lang.rx.TypeArg<V> __typeArg_1
public KafkaProducerRecord(KafkaProducerRecord delegate)
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 KafkaProducerRecord<K,V> addHeader(String key, String value)
addHeader(java.lang.String, java.lang.String)
but with a key/value pairkey
- value
- public KafkaProducerRecord<K,V> addHeader(String key, Buffer value)
addHeader(java.lang.String, java.lang.String)
but with a key/value pairkey
- value
- public KafkaProducerRecord<K,V> addHeader(KafkaHeader header)
header
- the headerpublic KafkaProducerRecord<K,V> addHeaders(List<KafkaHeader> headers)
headers
- the headerspublic List<KafkaHeader> headers()
public static <K,V> KafkaProducerRecord<K,V> newInstance(KafkaProducerRecord arg)
public static <K,V> KafkaProducerRecord<K,V> newInstance(KafkaProducerRecord arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)
Copyright © 2022 Eclipse. All rights reserved.