static Properties getProperties(final Arguments arguments) throws IOException {
    final Properties props = new Properties();
    props.put("bootstrap.servers", arguments.bootstrapServer);
    props.put("client.id", "KSQLDataGenProducer");
    props.put(KsqlConfig.SCHEMA_REGISTRY_URL_PROPERTY, arguments.schemaRegistryUrl);

    if (arguments.propertiesFile != null) {
      props.load(arguments.propertiesFile);
    }

    return props;
  }
@Test
  public void shouldPassSchemaRegistryUrl() throws Exception {
    final DataGen.Arguments args = new DataGen.Arguments(
        false,
        "bootstrap",
        null,
        null,
        null,
        null,
        "topic",
        "key",
        null,
        0,
        "srUrl",
        null,
        1,
        -1,
        true
    );

    final Properties props = DataGen.getProperties(args);
    assertThat(props.getProperty(KsqlConfig.SCHEMA_REGISTRY_URL_PROPERTY), equalTo("srUrl"));
  }