public KsqlTarget target(final URI server) {
    return target(server, Collections.emptyMap());
  }
@Test
  public void shouldSendKsqlRequest() {

    // Given:
    String ksql = "some ksql";
    Object expectedResponse = setupExpectedResponse();

    // When:
    KsqlTarget target = ksqlClient.target(serverUri);
    RestResponse<KsqlEntityList> resp = target.postKsqlRequest(ksql, Collections.emptyMap(), Optional.of(123L));

    // Then:
    assertThat(resp.get(), is(expectedResponse));
    assertThat(server.getHttpMethod(), is(HttpMethod.POST));
    assertThat(server.getPath(), is("/ksql"));
    assertThat(server.getHeaders().get("Accept"), is("application/json"));
    assertThat(getKsqlRequest(),
        is(new KsqlRequest(ksql, properties, Collections.emptyMap(), 123L)));
  }