@Override
  public void handle(final ClassicHttpResponse response) {
    final int statusCode = response.getCode();
    try {
      if (statusCode == HttpStatus.SC_OK && response.getEntity().getContent() != null) {

        final String content = EntityUtils.toString(response.getEntity());
        if (content.length() > 0) {
          log.warn(content);
        }
      }
    } catch (final ParseException | IOException e) {
      log.error("Error while parsing the Version check response ", e);
    }
  }
@Test
  public void testHandle() throws IOException {
    // Given
    final ClassicHttpResponse response = mock(ClassicHttpResponse.class);
    final HttpEntity entity = mock(HttpEntity.class);
    final Logger log = mock(Logger.class);
    expect(response.getCode()).andReturn(HttpStatus.SC_OK).once();
    expect(response.getEntity()).andReturn(entity).times(2);
    final ByteArrayInputStream bais = new ByteArrayInputStream("yolo".getBytes(StandardCharsets.UTF_8));
    expect(entity.getContent()).andReturn(bais).times(2);
    expect(entity.getContentType()).andReturn("content-type").times(1);
    expect(entity.getContentLength()).andReturn(4L).times(1);
    log.warn("yolo");
    expectLastCall().once();
    replay(response, entity, log);

    final KsqlVersionCheckerResponseHandler kvcr = new KsqlVersionCheckerResponseHandler(log);

    // When
    kvcr.handle(response);

    // Then
    verify(response, entity, log);
  }