Uses of Class
io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord

Packages that use KafkaProducerRecord

Package	Description
io.vertx.reactivex.kafka.client.producer

Uses of KafkaProducerRecord in io.vertx.reactivex.kafka.client.producer

Fields in io.vertx.reactivex.kafka.client.producer with type parameters of type KafkaProducerRecord

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<KafkaProducerRecord>	KafkaProducerRecord.__TYPE_ARG

Methods in io.vertx.reactivex.kafka.client.producer that return KafkaProducerRecord

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)

Methods in io.vertx.reactivex.kafka.client.producer that return types with arguments of type KafkaProducerRecord

Modifier and Type	Method and Description
io.vertx.reactivex.WriteStreamObserver<KafkaProducerRecord<K,V>>	KafkaProducer.toObserver()
io.vertx.reactivex.WriteStreamSubscriber<KafkaProducerRecord<K,V>>	KafkaProducer.toSubscriber()

Methods in io.vertx.reactivex.kafka.client.producer with parameters of type KafkaProducerRecord

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
Completable	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
Completable	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)