Uses of Class io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord (Vert.x Stack - Docs 5.0.5 API)

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	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	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	Description
`WriteStreamObserver<KafkaProducerRecord<K,V>>`	KafkaProducer.`toObserver()`
`WriteStreamSubscriber<KafkaProducerRecord<K,V>>`	KafkaProducer.`toSubscriber()`

Methods in io.vertx.reactivex.kafka.client.producer with parameters of type KafkaProducerRecord
Modifier and Type	Method	Description
`Future<Void>`	KafkaProducer.`end(KafkaProducerRecord<K,V> data)`	Same as `WriteStream.end()` but writes some data to the stream before ending.
`Completable`	KafkaProducer.`rxEnd(KafkaProducerRecord<K,V> data)`	Same as `WriteStream.end()` but writes some data to the stream before ending.
`Single<RecordMetadata>`	KafkaProducer.`rxSend(KafkaProducerRecord<K,V> record)`	Asynchronously write a record to a topic
`Completable`	KafkaProducer.`rxWrite(KafkaProducerRecord<K,V> data)`	Write some data to the stream.
`Future<RecordMetadata>`	KafkaProducer.`send(KafkaProducerRecord<K,V> record)`	Asynchronously write a record to a topic
`Future<Void>`	KafkaProducer.`write(KafkaProducerRecord<K,V> data)`	Write some data to the stream.