KsqlInternalTopicUtils¶

ensureTopic¶

void ensureTopic(
  String name,
  KsqlConfig ksqlConfig,
  KafkaTopicClient topicClient)

ensureTopic...FIXME

ensureTopic is used when:

• KsqlRestApplication is requested to registerCommandTopic
• StandaloneExecutorFactory is requested to create a StandaloneExecutor
• KsqlRestoreCommandTopic is requested to restore