### Question:
KsqlRestConfig extends RestConfig { public String getCommandTopic(String ksqlServiceId) { return String.format( "%s%s_%s", KsqlConstants.KSQL_INTERNAL_TOPIC_PREFIX, ksqlServiceId, COMMAND_TOPIC_SUFFIX ); } KsqlRestConfig(Map<?, ?> props); Map<String, Object> getOriginals(); Map<String, Object> getCommandConsumerProperties(); Map<String, Object> getCommandProducerProperties(); Map<String, Object> getKsqlConfigProperties(); String getCommandTopic(String ksqlServiceId); boolean isUiEnabled(); static final String COMMAND_CONSUMER_PREFIX; static final String COMMAND_PRODUCER_PREFIX; static final String STREAMED_QUERY_DISCONNECT_CHECK_MS_CONFIG; static final ConfigDef.Type STREAMED_QUERY_DISCONNECT_CHECK_MS_TYPE; static final Long STREAMED_QUERY_DISCONNECT_CHECK_MS_DEFAULT; static final ConfigDef.Importance STREAMED_QUERY_DISCONNECT_CHECK_MS_IMPORTANCE; static final String STREAMED_QUERY_DISCONNECT_CHECK_MS_DOC; static final String DISTRIBUTED_COMMAND_RESPONSE_TIMEOUT_MS_CONFIG; static final ConfigDef.Type DISTRIBUTED_COMMAND_RESPONSE_TIMEOUT_MS_TYPE; static final Long DISTRIBUTED_COMMAND_RESPONSE_TIMEOUT_MS_DEFAULT; static final ConfigDef.Importance DISTRIBUTED_COMMAND_RESPONSE_TIMEOUT_MS_IMPORTANCE; static final String DISTRIBUTED_COMMAND_RESPONSE_TIMEOUT_MS_DOC; static final String UI_ENABLED_CONFIG; static final ConfigDef.Type UI_ENABLED_TYPE; static final String UI_ENABLED_DEFAULT; static final ConfigDef.Importance UI_ENABLED_IMPORTANCE; static final String UI_ENABLED_DOC; static final String INSTALL_DIR_CONFIG; static final String INSTALL_DIR_DOC; static final String COMMAND_TOPIC_SUFFIX; static final String KSQL_WEBSOCKETS_NUM_THREADS; }### Answer:
@Test public void ensureCorrectCommandTopicName() { KsqlRestConfig config = new KsqlRestConfig(getBaseProperties()); String commandTopicName = config.getCommandTopic("TestKSql"); assertThat(commandTopicName, equalTo("_confluent-ksql-TestKSql_" + KsqlRestConfig.COMMAND_TOPIC_SUFFIX)); }