KafkaConfig

data class KafkaConfig( val consumerCount: Int, val topics: List<String>, val datasetIds: Map<String, String>, val bootstrapServers: List<String>, val groupId: String, val nestingBehavior: KafkaNestingBehavior)

Constructors

fun KafkaConfig( consumerCount: Int, topics: List<String>, datasetIds: Map<String, String>, bootstrapServers: List<String>, groupId: String, nestingBehavior: KafkaNestingBehavior)