gobblin-completeness/src/main/java/org/apache/gobblin/completeness/audit/AuditCountHttpClient.java [144:169]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private String getHttpResponse(String fullUrl) throws IOException {
    HttpUriRequest req = new HttpGet(fullUrl);

    for (int numTries = 0;; numTries++) {
      try (CloseableHttpResponse response = this.httpClient.execute(req)) {
        int statusCode = response.getStatusLine().getStatusCode();
        if (statusCode < 200 || statusCode >= 300) {
          throw new IOException(
                  String.format("status code: %d, reason: %s", statusCode, response.getStatusLine().getReasonPhrase()));
        }
        return EntityUtils.toString(response.getEntity());
      } catch (IOException e) {
        String errMsg = "Unable to get or parse HTTP response for " + fullUrl;
        if (numTries >= this.maxNumTries) {
          throw new IOException (errMsg, e);
        }
        long backOffSec = (numTries + 1) * 2;
        log.error(errMsg + ", will retry in " + backOffSec + " sec", e);
        try {
          Thread.sleep(TimeUnit.SECONDS.toMillis(backOffSec));
        } catch (InterruptedException e1) {
          Thread.currentThread().interrupt();
        }
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClient.java [155:180]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private String getHttpResponse(String fullUrl) throws IOException {
    HttpUriRequest req = new HttpGet(fullUrl);

    for (int numTries = 0;; numTries++) {
      try (CloseableHttpResponse response = this.httpClient.execute(req)) {
        int statusCode = response.getStatusLine().getStatusCode();
        if (statusCode < 200 || statusCode >= 300) {
          throw new IOException(
                  String.format("status code: %d, reason: %s", statusCode, response.getStatusLine().getReasonPhrase()));
        }
        return EntityUtils.toString(response.getEntity());
      } catch (IOException e) {
        String errMsg = "Unable to get or parse HTTP response for " + fullUrl;
        if (numTries >= this.maxNumTries) {
          throw new IOException (errMsg, e);
        }
        long backOffSec = (numTries + 1) * 2;
        log.error(errMsg + ", will retry in " + backOffSec + " sec", e);
        try {
          Thread.sleep(TimeUnit.SECONDS.toMillis(backOffSec));
        } catch (InterruptedException e1) {
          Thread.currentThread().interrupt();
        }
      }
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -