ProcessingLogServerUtils¶

maybeCreateProcessingLogTopic¶

Optional<String> maybeCreateProcessingLogTopic(
  KafkaTopicClient topicClient,
  ProcessingLogConfig config,
  KsqlConfig ksqlConfig)

maybeCreateProcessingLogTopic...FIXME

maybeCreateProcessingLogTopic is used when:

• KsqlRestApplication is requested to initialize
• StandaloneExecutor is requested to startAsync