Skip to content

ReservedInternalTopics

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:

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

commandTopic is used when:

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:

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:

Back to top