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

Packages that use KafkaProducer

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

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

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

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<KafkaProducer>	KafkaProducer.__TYPE_ARG

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

Modifier and Type	Method and Description
KafkaProducer<K,V>	KafkaProducer.abortTransaction() Aborts the ongoing transaction.
KafkaProducer<K,V>	KafkaProducer.abortTransaction(Handler<AsyncResult<Void>> handler) Aborts the ongoing transaction.
KafkaProducer<K,V>	KafkaProducer.beginTransaction() Starts a new kafka transaction.
KafkaProducer<K,V>	KafkaProducer.beginTransaction(Handler<AsyncResult<Void>> handler) Starts a new kafka transaction.
KafkaProducer<K,V>	KafkaProducer.commitTransaction() Commits the ongoing transaction.
KafkaProducer<K,V>	KafkaProducer.commitTransaction(Handler<AsyncResult<Void>> handler) Commits the ongoing transaction.
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, org.apache.kafka.clients.producer.Producer<K,V> producer) Create a new KafkaProducer instance from a native .
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, org.apache.kafka.clients.producer.Producer<K,V> producer, KafkaClientOptions options) Create a new KafkaProducer instance from a native .
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, KafkaClientOptions options) 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, KafkaClientOptions options, 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) 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
KafkaProducer<K,V>	KafkaProducer.drainHandler(Handler<Void> handler)
KafkaProducer<K,V>	KafkaProducer.exceptionHandler(Handler<Throwable> handler)
KafkaProducer<K,V>	KafkaProducer.flush() Invoking this method makes all buffered records immediately available to write
KafkaProducer<K,V>	KafkaProducer.flush(Handler<AsyncResult<Void>> completionHandler) Invoking this method makes all buffered records immediately available to write
KafkaProducer<K,V>	KafkaProducer.initTransactions() Initializes the underlying kafka transactional producer.
KafkaProducer<K,V>	KafkaProducer.initTransactions(Handler<AsyncResult<Void>> handler) Initializes the underlying kafka transactional producer.
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)
KafkaProducer<K,V>	KafkaProducer.partitionsFor(String topic) Get the partition metadata for the give topic.
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)