Package | Description |
---|---|
io.vertx.rxjava.kafka.client.producer |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<KafkaProducerRecord> |
KafkaProducerRecord.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(KafkaHeader header)
Add an header to this record.
|
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(String key,
Buffer value)
Like
addHeader(java.lang.String, java.lang.String) but with a key/value pair |
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(String key,
String value)
Like
addHeader(java.lang.String, java.lang.String) but with a key/value pair |
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeaders(List<KafkaHeader> headers)
Add a list of headers to this record.
|
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,
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
|
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.newInstance(KafkaProducerRecord arg) |
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.newInstance(KafkaProducerRecord arg,
io.vertx.lang.rx.TypeArg<K> __typeArg_K,
io.vertx.lang.rx.TypeArg<V> __typeArg_V) |
Modifier and Type | Method and Description |
---|---|
io.vertx.rx.java.WriteStreamSubscriber<KafkaProducerRecord<K,V>> |
KafkaProducer.toSubscriber() |
Modifier and Type | Method and Description |
---|---|
void |
KafkaProducer.end(KafkaProducerRecord<K,V> data)
Same as
WriteStream.end() but writes some data to the stream before ending. |
void |
KafkaProducer.end(KafkaProducerRecord<K,V> data,
Handler<AsyncResult<Void>> handler)
Same as but with an
handler called when the operation completes |
Single<Void> |
KafkaProducer.rxEnd(KafkaProducerRecord<K,V> data)
Same as but with an
handler called when the operation completes |
Single<RecordMetadata> |
KafkaProducer.rxSend(KafkaProducerRecord<K,V> record)
Asynchronously write a record to a topic
|
Single<Void> |
KafkaProducer.rxWrite(KafkaProducerRecord<K,V> data) |
KafkaProducer<K,V> |
KafkaProducer.send(KafkaProducerRecord<K,V> record)
Asynchronously write a record to a topic
|
KafkaProducer<K,V> |
KafkaProducer.send(KafkaProducerRecord<K,V> record,
Handler<AsyncResult<RecordMetadata>> handler)
Asynchronously write a record to a topic
|
KafkaProducer<K,V> |
KafkaProducer.write(KafkaProducerRecord<K,V> kafkaProducerRecord) |
KafkaProducer<K,V> |
KafkaProducer.write(KafkaProducerRecord<K,V> data,
Handler<AsyncResult<Void>> handler) |
Copyright © 2023 Eclipse. All rights reserved.