open fun setWriteQueueMaxSize(i: Int): KafkaProducer<K, V>
Overrides WriteStream.setWriteQueueMaxSize