KafkaTopicProducer

constructor(producer: Producer<String, ByteArray>, dispatcher: CoroutineDispatcher, closeTimeout: Duration)
constructor(producer: Producer<String, ByteArray>, dispatcher: CoroutineDispatcher = VirtualThreads.dispatcher)