public DropSourceCommand create(final DropStream statement) {
    return create(
        statement.getName(),
        statement.getIfExists(),
        statement.isDeleteTopic(),
        DataSourceType.KSTREAM
    );
  }
@Test
  public void shouldCreateDropSourceOnMissingSourceWithIfExistsForStream() {
    // Given:
    final DropStream dropStream = new DropStream(SOME_NAME, true, true);
    when(metaStore.getSource(SOME_NAME)).thenReturn(null);

    // When:
    final DropSourceCommand cmd = dropSourceFactory.create(dropStream);

    // Then:
    assertThat(cmd.getSourceName(), equalTo(SourceName.of("bob")));
  }