@Override
  public void start(final QueryId queryId) {
  }
@Test
  public void shouldStartQuery() {
    //When:
    validationSharedKafkaStreamsRuntime.start(queryId);

    //Then:
    assertThat("Query was not added", validationSharedKafkaStreamsRuntime.getQueries().contains(queryId));
  }