kafka/ru.sydis.kafka.consumer/GlobalConsumer

GlobalConsumer

class GlobalConsumer<T>

Types

object Companion

Functions

addFilterWithCallback

fun addFilterWithCallback(filter: (ConsumerRecord<ByteArray, T>) -> Boolean, callback: (ConsumerRecord<ByteArray, T>) -> Unit)

consumeMessages

fun consumeMessages()

fun isConsumerRun(): Boolean

fun stopConsume()