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

Classes in io.vertx.reactivex.kafka.client.producer that implement interfaces with type arguments of type KafkaProducerRecord

Modifier and Type	Class	Description
class	KafkaProducer<K,V>	Vert.x Kafka producer.

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

Modifier and Type	Field	Description
static final 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 KafkaProducerRecord.addHeader(String, String) but with a key/value pair
KafkaProducerRecord<K,V>	KafkaProducerRecord.addHeader(String key, String value)	Like KafkaProducerRecord.addHeader(String, 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.