| Package | Description |
|---|---|
| io.vertx.kafka.client.producer | |
| io.vertx.reactivex.kafka.client.producer | |
| io.vertx.rxjava.kafka.client.producer |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.create(String topic,
K key,
V value)
Create a concrete instance of a Vert.x producer record
|
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.create(String topic,
K key,
V value,
Integer partition)
Create a concrete instance of a Vert.x producer record
|
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.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> |
KafkaProducerRecord.create(String topic,
V value)
Create a concrete instance of a Vert.x producer record
|
| Modifier and Type | Method and Description |
|---|---|
void |
KafkaProducer.end(KafkaProducerRecord<K,V> kafkaProducerRecord) |
KafkaProducer<K,V> |
KafkaProducer.write(KafkaProducerRecord<K,V> kafkaProducerRecord) |
KafkaProducer<K,V> |
KafkaProducer.write(KafkaProducerRecord<K,V> record,
Handler<AsyncResult<RecordMetadata>> handler)
Asynchronously write a record to a topic
|
| Modifier and Type | Method and Description |
|---|---|
KafkaProducerRecord |
KafkaProducerRecord.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.newInstance(KafkaProducerRecord arg) |
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.newInstance(KafkaProducerRecord arg,
TypeArg<K> __typeArg_K,
TypeArg<V> __typeArg_V) |
| Constructor and Description |
|---|
KafkaProducerRecord(KafkaProducerRecord delegate) |
KafkaProducerRecord(KafkaProducerRecord delegate,
TypeArg<K> typeArg_0,
TypeArg<V> typeArg_1) |
| Modifier and Type | Method and Description |
|---|---|
KafkaProducerRecord |
KafkaProducerRecord.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.newInstance(KafkaProducerRecord arg) |
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.newInstance(KafkaProducerRecord arg,
TypeArg<K> __typeArg_K,
TypeArg<V> __typeArg_V) |
| Constructor and Description |
|---|
KafkaProducerRecord(KafkaProducerRecord delegate) |
KafkaProducerRecord(KafkaProducerRecord delegate,
TypeArg<K> typeArg_0,
TypeArg<V> typeArg_1) |
Copyright © 2018 Eclipse. All rights reserved.