switch (SchemaRepositoryType.valueOf(schemaRepositoryType)) {
case SCHEMA_REPO:
return new SchemaRepoSchemaSourceProvider(schemaRepoClient);
case ZOOKEEPER:
return new ZookeeperSchemaSourceProvider(curatorFramework, zookeeperPaths);
<BUG>case TOPIC_FIELD:
return new TopicFieldSchemaSourceProvider();</BUG>
default:
throw new IllegalStateException("Unknown schema repository type " + schemaRepositoryType);
}

switch (SchemaRepositoryType.valueOf(schemaRepositoryType)) {
case SCHEMA_REPO:
return new SchemaRepoSchemaSourceProvider(schemaRepoClient);
case ZOOKEEPER:
return new ZookeeperSchemaSourceProvider(curatorFramework, zookeeperPaths);
default:
throw new IllegalStateException("Unknown schema repository type " + schemaRepositoryType);
