@Override
  public CompletableFuture<StreamedQueryResult> continueFromLastContinuationToken() {
    if (!this.hasContinuationToken()) {
      throw new KsqlClientException(
          "Can only continue queries that have saved a continuation token.");
    }
    return this.client.streamQuery(sql, properties);
  }
@Test
  public void shouldThrowOnContinueIfNoContinuationToken() {
    // When
    final Exception e = assertThrows(
        KsqlClientException.class,
        () -> queryResult.continueFromLastContinuationToken().get()
    );

    // Then
    assertThat(e.getMessage(), containsString("Can only continue queries that have saved a continuation token."));
  }