Uses of Interface
io.vertx.kafka.client.producer.KafkaProducer

Packages that use KafkaProducer

Package	Description
io.vertx.kafka.client.producer
io.vertx.reactivex.kafka.client.producer
io.vertx.rxjava.kafka.client.producer

Uses of KafkaProducer in io.vertx.kafka.client.producer

Methods in io.vertx.kafka.client.producer that return KafkaProducer

Modifier and Type	Method and Description
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Map<String,String> config) Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Map<String,String> config, Class<K> keyType, Class<V> valueType) Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Map<String,String> config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer) Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, org.apache.kafka.clients.producer.Producer<K,V> producer) Create a new KafkaProducer instance from a native Producer.
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Properties config) Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Properties config, Class<K> keyType, Class<V> valueType) Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Properties config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer) Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Map<String,String> config) Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Map<String,String> config, Class<K> keyType, Class<V> valueType) Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Map<String,String> config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer) Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Properties config) Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Properties config, Class<K> keyType, Class<V> valueType) Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Properties config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer) Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
KafkaProducer<K,V>	KafkaProducer.drainHandler(Handler<Void> handler)
KafkaProducer<K,V>	KafkaProducer.exceptionHandler(Handler<Throwable> handler)
KafkaProducer<K,V>	KafkaProducer.flush(Handler<Void> completionHandler) Invoking this method makes all buffered records immediately available to write
KafkaProducer<K,V>	KafkaProducer.partitionsFor(String topic, Handler<AsyncResult<List<PartitionInfo>>> handler) Get the partition metadata for the give topic.
KafkaProducer<K,V>	KafkaProducer.send(KafkaProducerRecord<K,V> record) Asynchronously write a record to a topic
KafkaProducer<K,V>	KafkaProducer.send(KafkaProducerRecord<K,V> record, Handler<AsyncResult<RecordMetadata>> handler) Asynchronously write a record to a topic
KafkaProducer<K,V>	KafkaProducer.setWriteQueueMaxSize(int i)
KafkaProducer<K,V>	KafkaProducer.write(KafkaProducerRecord<K,V> kafkaProducerRecord)
KafkaProducer<K,V>	KafkaProducer.write(KafkaProducerRecord<K,V> data, Handler<AsyncResult<Void>> handler)

Uses of KafkaProducer in io.vertx.reactivex.kafka.client.producer

Methods in io.vertx.reactivex.kafka.client.producer that return KafkaProducer

Modifier and Type	Method and Description
KafkaProducer	KafkaProducer.getDelegate()

Methods in io.vertx.reactivex.kafka.client.producer with parameters of type KafkaProducer

Modifier and Type	Method and Description
static <K,V> KafkaProducer<K,V>	KafkaProducer.newInstance(KafkaProducer arg)
static <K,V> KafkaProducer<K,V>	KafkaProducer.newInstance(KafkaProducer 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 KafkaProducer

Constructor and Description
KafkaProducer(KafkaProducer delegate)

Uses of KafkaProducer in io.vertx.rxjava.kafka.client.producer

Methods in io.vertx.rxjava.kafka.client.producer that return KafkaProducer

Modifier and Type	Method and Description
KafkaProducer	KafkaProducer.getDelegate()

Methods in io.vertx.rxjava.kafka.client.producer with parameters of type KafkaProducer

Modifier and Type	Method and Description
static <K,V> KafkaProducer<K,V>	KafkaProducer.newInstance(KafkaProducer arg)
static <K,V> KafkaProducer<K,V>	KafkaProducer.newInstance(KafkaProducer arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)

Constructors in io.vertx.rxjava.kafka.client.producer with parameters of type KafkaProducer

Constructor and Description
KafkaProducer(KafkaProducer delegate)