#vulnerable code 
                              private void createStreams(final String host) throws Exception {
    appServerPort = randomFreeLocalPort();
    streams = KafkaMusicExample.createChartsStreams(CLUSTER.bootstrapServers(),
                                                    CLUSTER.schemaRegistryUrl(),
                                                    appServerPort,
                                                    TestUtils.tempDirectory().getPath(),
                                                    host);
    int count = 0;
    final int maxTries = 3;
    while (count <= maxTries) {
      try {
        // Starts the Rest Service on the provided host:port
        restProxy = KafkaMusicExample.startRestProxy(streams, new HostInfo(host, appServerPort));
      } catch (final Exception ex) {
        log.error("Could not start Rest Service due to: " + ex.toString());
      }
      count++;
    }
  } 
                            #location 13 
                            #vulnerability type RESOURCE_LEAK
#fixed code
                              private void createStreams(final String host) throws Exception {
    appServerPort = randomFreeLocalPort();
    streams = KafkaMusicExample.createChartsStreams(CLUSTER.bootstrapServers(),
                                                    CLUSTER.schemaRegistryUrl(),
                                                    appServerPort,
                                                    TestUtils.tempDirectory().getPath(),
                                                    host);
    int count = 0;
    final int maxTries = 3;
    while (count <= maxTries) {
      try {
        // Starts the Rest Service on the provided host:port
        restProxy = KafkaMusicExample.startRestProxy(streams, new HostInfo(host, appServerPort));
        break;
      } catch (final Exception ex) {
        log.error("Could not start Rest Service due to: " + ex.toString());
      }
      count++;
    }
  }