public KsqlTopic getPrimarySourceTopic() {
    return primarySourceTopic;
  }
@Test
  public void shouldExtractTopicFromSimpleSelect() {
    // Given:
    final Statement statement = givenStatement("SELECT * FROM " + STREAM_TOPIC_1 + ";");

    // When:
    extractor.process(statement, null);

    // Then:
    assertThat(extractor.getPrimarySourceTopic(), is(TOPIC_1));
  }