open fun close(): Unit
Closes the producer, this method should be called when the message producer is not used anymore.