class KsqlVersionCheckerResponseHandler implements ResponseHandler {

  @Override
  public void handle(HttpResponse response) {
    int statusCode = response.getStatusLine().getStatusCode();
    try {
      if (statusCode == HttpStatus.SC_OK && response.getEntity().getContent() != null) {

        String content = EntityUtils.toString(response.getEntity());
        if (content.length() > 0) {
          log.warn(content.toString());
        }
      }
    } catch (IOException e) {
      log.error("Error while parsing the Version check response ", e);
    }
  }

    KsqlVersionCheckerResponseHandler();
  @VisibleForTesting  KsqlVersionCheckerResponseHandler(Logger log);

}