ReservedInternalTopics¶

Creating Instance¶

ReservedInternalTopics takes the following to be created:

• KsqlConfig

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:

_confluent-ksql-[ksql.service.id]_command_topic

commandTopic is used when:

• HealthCheckAgent.KafkaBrokerCheck is requested to check
• KsqlRestApplication utility is used to build a KsqlRestApplication (and creates a CommandStore)
• KsqlRestoreCommandTopic is created

Configs Topic¶

String configsTopic(
  KsqlConfig ksqlConfig)

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

_confluent-ksql-[ksql.service.id]_configs

configsTopic is used when:

• StandaloneExecutorFactory utility is used to create a StandaloneExecutor

toKsqlInternalTopic¶

String toKsqlInternalTopic(
  KsqlConfig ksqlConfig,
  String topicSuffix)

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

_confluent-ksql-[ksql.service.id]_[topicSuffix]

toKsqlInternalTopic is used when:

• ReservedInternalTopics utility is used for commandTopic and configsTopic