class JdbcSource implements SupportedConnector {

  @VisibleForTesting
  Optional<Connector> fromConfigs(final Map<String, String> properties) {
    final String name = properties.get("name");
    return Optional.of(new Connector(
        name,
        DataSourceType.KTABLE,
        extractKeyNameFromSmt(properties).orElse(null)
    ));
  }

}