KafkaKonsument

constructor(topic: String, config: KafkaConsumerConfig, consumerName: String, pollTimeout: Duration, closeTimeout: Duration)(source)