kafka-utils/dev.limebeck.libs.kafka/KafkaListener

KafkaListener

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

Constructors

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

Types

object Companion

Functions

open override fun close()

suspend fun run(): Job