public static String commandTopic(final KsqlConfig ksqlConfig) {
    return toKsqlInternalTopic(ksqlConfig, KSQL_COMMAND_TOPIC_SUFFIX);
  }
@Test
  public void shouldReturnCommandTopic() {
    // Given/When
    final String commandTopic = ReservedInternalTopics.commandTopic(ksqlConfig);

    // Then
    assertThat(commandTopic, is("_confluent-ksql-default__command_topic"));
  }