| 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 | 
|---|---|
RecordMetadata | 
RecordMetadata.setChecksum(long checksum)
Set the checksum (CRC32) of the record. 
 | 
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 | 
|---|---|
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 
 | 
Copyright © 2020 Eclipse. All rights reserved.