whylogs-container/ai.whylabs.services.whylogs.kafka/KotlinConsumer

KotlinConsumer

class KotlinConsumer<K, V>(    config: KotlinConsumerConfig<K, V>,     valueType: TypeReference<V>,     keyType: TypeReference<K>,     process: suspend (record: KafkaRecord<K, V>) -> Boolean)
Content copied to clipboard

Constructors

Link copied to clipboard
fun <K, V> KotlinConsumer(    config: KotlinConsumerConfig<K, V>,     valueType: TypeReference<V>,     keyType: TypeReference<K>,     process: suspend (record: KafkaRecord<K, V>) -> Boolean)
Content copied to clipboard

Types

Link copied to clipboard
object Companion
Content copied to clipboard

Functions

Link copied to clipboard
fun start()
Content copied to clipboard