Package | Description |
---|---|
io.vertx.kafka.client.producer | |
io.vertx.reactivex.kafka.client.producer | |
io.vertx.rxjava.kafka.client.producer | |
io.vertx.rxjava3.kafka.client.producer |
Modifier and Type | Method and Description |
---|---|
RecordMetadata |
RecordMetadata.setOffset(long offset)
Set the offset of the record in the topic/partition.
|
RecordMetadata |
RecordMetadata.setPartition(int partition)
Set the partition the record was sent to
|
RecordMetadata |
RecordMetadata.setTimestamp(long timestamp)
Set the timestamp of the record in the topic/partition
|
RecordMetadata |
RecordMetadata.setTopic(String topic)
Set the topic the record was appended to
|
Modifier and Type | Method and Description |
---|---|
Future<RecordMetadata> |
KafkaProducer.send(KafkaProducerRecord<K,V> record)
Asynchronously write a record to a topic
|
Modifier and Type | Method and Description |
---|---|
KafkaProducer<K,V> |
KafkaProducer.send(KafkaProducerRecord<K,V> record,
Handler<AsyncResult<RecordMetadata>> handler)
Asynchronously write a record to a topic
|
Modifier and Type | Method and Description |
---|---|
Single<RecordMetadata> |
KafkaProducer.rxSend(KafkaProducerRecord<K,V> record)
Asynchronously write a record to a topic
|
Modifier and Type | Method and Description |
---|---|
KafkaProducer<K,V> |
KafkaProducer.send(KafkaProducerRecord<K,V> record,
Handler<AsyncResult<RecordMetadata>> handler)
Asynchronously write a record to a topic
|
Modifier and Type | Method and Description |
---|---|
Single<RecordMetadata> |
KafkaProducer.rxSend(KafkaProducerRecord<K,V> record)
Asynchronously write a record to a topic
|
Modifier and Type | Method and Description |
---|---|
KafkaProducer<K,V> |
KafkaProducer.send(KafkaProducerRecord<K,V> record,
Handler<AsyncResult<RecordMetadata>> handler)
Asynchronously write a record to a topic
|
Modifier and Type | Method and Description |
---|---|
Single<RecordMetadata> |
KafkaProducer.rxSend(KafkaProducerRecord<K,V> record)
Asynchronously write a record to a topic
|
Single<RecordMetadata> |
KafkaProducer.send(KafkaProducerRecord<K,V> record)
Asynchronously write a record to a topic
|
Copyright © 2023 Eclipse. All rights reserved.