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

Companion

object Companion
Content copied to clipboard

Functions

Link copied to clipboard
inline fun <K, V> consumer(config: KotlinConsumerConfig<K, V>, noinline processor: suspend (record: KafkaRecord<K, V>) -> Boolean): KotlinConsumer<K, V>
Content copied to clipboard