SchemaRegistryConfig
data class SchemaRegistryConfig(val url: String = requiredConfigForKey("KAFKA_SCHEMA_REGISTRY"), val user: String = requiredConfigForKey("KAFKA_SCHEMA_REGISTRY_USER"), val password: String = requiredConfigForKey("KAFKA_SCHEMA_REGISTRY_PASSWORD"))(source)