Uses of Interface
io.vertx.kafka.client.producer.KafkaProducerRecord
-
Packages that use KafkaProducerRecord Package Description io.vertx.kafka.client.producer io.vertx.reactivex.kafka.client.producer io.vertx.rxjava3.kafka.client.producer -
-
Uses of KafkaProducerRecord in io.vertx.kafka.client.producer
Methods in io.vertx.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)
LikeaddHeader(KafkaHeader)
but with a key/value pairKafkaProducerRecord<K,V>
KafkaProducerRecord. addHeader(String key, String value)
LikeaddHeader(KafkaHeader)
but with a key/value pairKafkaProducerRecord<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 recordstatic <K,V>
KafkaProducerRecord<K,V>KafkaProducerRecord. create(String topic, K key, V value, Integer partition)
Create a concrete instance of a Vert.x producer recordstatic <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 recordstatic <K,V>
KafkaProducerRecord<K,V>KafkaProducerRecord. create(String topic, V value)
Create a concrete instance of a Vert.x producer recordMethods in io.vertx.kafka.client.producer with parameters of type KafkaProducerRecord Modifier and Type Method Description Future<RecordMetadata>
KafkaProducer. send(KafkaProducerRecord<K,V> record)
Asynchronously write a record to a topic -
Uses of KafkaProducerRecord in io.vertx.reactivex.kafka.client.producer
Methods in io.vertx.reactivex.kafka.client.producer that return KafkaProducerRecord Modifier and Type Method Description KafkaProducerRecord
KafkaProducerRecord. getDelegate()
Methods in io.vertx.reactivex.kafka.client.producer with parameters of type KafkaProducerRecord Modifier and Type Method Description 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)
Constructors in io.vertx.reactivex.kafka.client.producer with parameters of type KafkaProducerRecord Constructor Description KafkaProducerRecord(KafkaProducerRecord delegate)
-
Uses of KafkaProducerRecord in io.vertx.rxjava3.kafka.client.producer
Methods in io.vertx.rxjava3.kafka.client.producer that return KafkaProducerRecord Modifier and Type Method Description KafkaProducerRecord
KafkaProducerRecord. getDelegate()
Methods in io.vertx.rxjava3.kafka.client.producer with parameters of type KafkaProducerRecord Modifier and Type Method Description 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)
Constructors in io.vertx.rxjava3.kafka.client.producer with parameters of type KafkaProducerRecord Constructor Description KafkaProducerRecord(KafkaProducerRecord delegate)
-