open fun end(): Unit
Overrides WriteStream.end
open fun end(kafkaProducerRecord: KafkaProducerRecord<K, V>): Unit