KafkaListener

constructor(topicNames: List<String>, properties: KafkaListenerProperties<Key, Value>, pollDuration: Duration = Duration.ofMillis(100), processor: suspend (ConsumerRecord<Key, Value>) -> Unit)