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 final 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)	Add an header to this record.
KafkaProducerRecord<K,V>	KafkaProducerRecord.addHeader(String key, io.vertx.core.buffer.Buffer value)	Like addHeader(KafkaHeader) but with a key/value pair
KafkaProducerRecord<K,V>	KafkaProducerRecord.addHeader(String key, String value)	Like addHeader(KafkaHeader) 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(io.vertx.kafka.client.producer.KafkaProducerRecord<K,V> delegate)	Creates a new instance of the KafkaProducerRecord.
static <K, V> KafkaProducerRecord<K,V>	KafkaProducerRecord.newInstance(io.vertx.kafka.client.producer.KafkaProducerRecord<K,V> delegate, TypeArg<K> typeArg_0, TypeArg<V> typeArg_1)	Creates a new instance of the KafkaProducerRecord.

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

Modifier and Type	Method	Description
Flow.Subscriber<KafkaProducerRecord<K,V>>	KafkaProducer.toSubscriber()	Converts the current write stream to a subscriber.

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)	Same as KafkaProducer.end() but writes some data to the stream before ending.
void	KafkaProducer.endAndAwait(KafkaProducerRecord<K,V> data)	Same as KafkaProducer.end() but writes some data to the stream before ending.
KafkaProducer<K,V>	KafkaProducer.endAndForget(KafkaProducerRecord<K,V> data)	Same as KafkaProducer.end() but writes some data to the stream before ending.
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)	Asynchronously write a record to a topic
KafkaProducer<K,V>	KafkaProducer.sendAndForget(KafkaProducerRecord<K,V> record)	Asynchronously write a record to a topic
io.smallrye.mutiny.Uni<Void>	KafkaProducer.write(KafkaProducerRecord<K,V> data)	Write some data to the stream.
void	KafkaProducer.writeAndAwait(KafkaProducerRecord<K,V> data)	Write some data to the stream.
KafkaProducer<K,V>	KafkaProducer.writeAndForget(KafkaProducerRecord<K,V> data)	Write some data to the stream.