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

Packages that use KafkaProducerRecord

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

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

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

Modifier and Type	Field	Description
static TypeArg<KafkaProducerRecord>	KafkaProducerRecord.__TYPE_ARG

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

Modifier and Type	Method	Description
KafkaProducerRecord<K,V>	KafkaProducerRecord.addHeader(KafkaHeader header)
KafkaProducerRecord<K,V>	KafkaProducerRecord.addHeader(String key, Buffer value)
KafkaProducerRecord<K,V>	KafkaProducerRecord.addHeader(String key, String value)
KafkaProducerRecord<K,V>	KafkaProducerRecord.addHeaders(List<KafkaHeader> headers)
static <K,V> KafkaProducerRecord<K,V>	KafkaProducerRecord.create(String topic, K key, V value)
static <K,V> KafkaProducerRecord<K,V>	KafkaProducerRecord.create(String topic, K key, V value, Long timestamp, Integer partition)
static <K,V> KafkaProducerRecord<K,V>	KafkaProducerRecord.create(String topic, V value)
static <K,V> KafkaProducerRecord<K,V>	KafkaProducerRecord.newInstance(io.vertx.kafka.client.producer.KafkaProducerRecord arg)
static <K,V> KafkaProducerRecord<K,V>	KafkaProducerRecord.newInstance(io.vertx.kafka.client.producer.KafkaProducerRecord arg, TypeArg<K> __typeArg_K, TypeArg<V> __typeArg_V)

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

Modifier and Type	Method	Description
WriteStreamSubscriber<KafkaProducerRecord<K,V>>	KafkaProducer.toSubscriber()

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

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	KafkaProducer.end(KafkaProducerRecord<K,V> data)
Void	KafkaProducer.endAndAwait(KafkaProducerRecord<K,V> data)
void	KafkaProducer.endAndForget(KafkaProducerRecord<K,V> data)
io.smallrye.mutiny.Uni<io.vertx.kafka.client.producer.RecordMetadata>	KafkaProducer.send(KafkaProducerRecord<K,V> record)	Asynchronously write a record to a topic
io.vertx.kafka.client.producer.RecordMetadata	KafkaProducer.sendAndAwait(KafkaProducerRecord<K,V> record)	Blocking variant of io.vertx.mutiny.kafka.client.producer.KafkaProducer#send(io.vertx.mutiny.kafka.client.producer.KafkaProducerRecord).
KafkaProducer<K,V>	KafkaProducer.sendAndForget(KafkaProducerRecord<K,V> record)	Variant of io.vertx.mutiny.kafka.client.producer.KafkaProducer#send(io.vertx.mutiny.kafka.client.producer.KafkaProducerRecord) that ignores the result of the operation.
io.smallrye.mutiny.Uni<Void>	KafkaProducer.write(KafkaProducerRecord<K,V> arg0)
Void	KafkaProducer.writeAndAwait(KafkaProducerRecord<K,V> arg0)
void	KafkaProducer.writeAndForget(KafkaProducerRecord<K,V> arg0)