All Superinterfaces:

StreamBase, WriteStream<org.apache.kafka.clients.producer.ProducerRecord<K,V>>
```
public interface KafkaWriteStream<K,V>
extends WriteStream<org.apache.kafka.clients.producer.ProducerRecord<K,V>>
```
A WriteStream for writing to Kafka ProducerRecord.
The WriteStream.write(Object) provides global control over writing a record.

Field Summary

Fields
Modifier and Type Field Description

static int DEFAULT_MAX_SIZE

Method Summary

All Methods Static Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`Future<Void>`	`abortTransaction()`	Aborts the ongoing transaction.
`Future<Void>`	`beginTransaction()`	Starts a new kafka transaction.
`Future<Void>`	`close()`	Close the stream
`Future<Void>`	`close(long timeout)`	Close the stream
`Future<Void>`	`commitTransaction()`	Commits the ongoing transaction.
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, KafkaClientOptions options)`	Create a new KafkaWriteStream instance
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, KafkaClientOptions options, Class<K> keyType, Class<V> valueType)`	Create a new KafkaWriteStream instance
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, KafkaClientOptions options, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)`	Create a new KafkaWriteStream instance
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, Map<String,Object> config)`	Create a new KafkaWriteStream instance
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, Map<String,Object> config, Class<K> keyType, Class<V> valueType)`	Create a new KafkaWriteStream instance
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, Map<String,Object> config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)`	Create a new KafkaWriteStream instance
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, Properties config)`	Create a new KafkaWriteStream instance
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, Properties config, Class<K> keyType, Class<V> valueType)`	Create a new KafkaWriteStream instance
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, Properties config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)`	Create a new KafkaWriteStream instance
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, org.apache.kafka.clients.producer.Producer<K,V> producer)`	Create a new KafkaWriteStream instance
`static <K,V> KafkaWriteStream<K,V>`	`create(Vertx vertx, org.apache.kafka.clients.producer.Producer<K,V> producer, KafkaClientOptions options)`	Create a new KafkaWriteStream instance.
`KafkaWriteStream<K,V>`	`drainHandler(Handler<Void> handler)`
`KafkaWriteStream<K,V>`	`exceptionHandler(Handler<Throwable> handler)`
`Future<Void>`	`flush()`	Invoking this method makes all buffered records immediately available to write
`Future<Void>`	`initTransactions()`	Initializes the underlying kafka transactional producer.
`Future<List<org.apache.kafka.common.PartitionInfo>>`	`partitionsFor(String topic)`	Get the partition metadata for the give topic.
`Future<org.apache.kafka.clients.producer.RecordMetadata>`	`send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)`	Asynchronously write a record to a topic
`KafkaWriteStream<K,V>`	`setWriteQueueMaxSize(int i)`
`org.apache.kafka.clients.producer.Producer<K,V>`	`unwrap()`

Methods inherited from interface io.vertx.core.streams.WriteStream
end, end, write, writeQueueFull

Field Detail
- DEFAULT_MAX_SIZE
```
static final int DEFAULT_MAX_SIZE
```
  See Also:
  
  Constant Field Values