@Override
  public RestResponse<KsqlEntityList> makeKsqlRequest(
      final URI serverEndPoint,
      final String sql,
      final Map<String, ?> requestProperties) {
    final KsqlTarget target = sharedClient
        .target(serverEndPoint);

    return getTarget(target)
        .postKsqlRequest(sql, requestProperties, Optional.empty());
  }
@Test
  public void shouldPostRequest() {
    // When:
    final RestResponse<KsqlEntityList> result = client.makeKsqlRequest(SERVER_ENDPOINT, "Sql", ImmutableMap.of());

    // Then:
    verify(target).postKsqlRequest("Sql", ImmutableMap.of(), Optional.empty());
    assertThat(result, is(response));
  }