Skip to content


Creating Instance

ReservedInternalTopics takes the following to be created:

ReservedInternalTopics is created mainly alongside a KsqlServerEndpoints and a DistributingExecutor but also when:

  • InsertValuesExecutor is requested to getDataSource
  • ListTopicsExecutor is requested to listTopics

Internal ksqlDB Topics

Command Topic

String commandTopic(
  KsqlConfig ksqlConfig)

commandTopic builds the name of a ksqlDB internal topic with command_topic topic suffix:


commandTopic is used when:

Configs Topic

String configsTopic(
  KsqlConfig ksqlConfig)

configsTopic builds the name of a ksqlDB internal topic with configs topic suffix:


configsTopic is used when:


String toKsqlInternalTopic(
  KsqlConfig ksqlConfig,
  String topicSuffix)

toKsqlInternalTopic builds a name (of a ksqlDB internal topic) in the following format (based on the in the given KsqlConfig and the given topicSuffix):


toKsqlInternalTopic is used when: