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

Package ai.whylabs.services.whylogs.kafka

Types

ConsumerController

class ConsumerController( envConfig: IEnvVars, profileManager: WhyLogsProfileManager, debugInfo: DebugInfoManager = DebugInfoManager.instance)

JSONObjectDeserializer

class JSONObjectDeserializer : Deserializer<Map<String, Any>>

data class KafkaRecord<K, V>( val value: V, val key: K?, val rawRecord: ConsumerRecord<String, String>)

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

KotlinConsumerConfig

data class KotlinConsumerConfig<K, V>( val consumerCount: Int = 1, val topics: List<String>, val bootstrapServers: List<String>, val groupId: String)