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

KotlinConsumerConfig

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

Constructors

KotlinConsumerConfig

fun KotlinConsumerConfig( consumerCount: Int = 1, topics: List<String>, bootstrapServers: List<String>, groupId: String)

Properties

bootstrapServers

val bootstrapServers: List<String>

val consumerCount: Int = 1

val groupId: String

val topics: List<String>