Skip to content


MetaStoreImpl is a MutableMetaStore.

Creating Instance

MetaStoreImpl takes the following to be created:

MetaStoreImpl is created when:


Map<SourceName, SourceInfo> dataSources

MetaStoreImpl starts with an empty dataSources registry when created.

A new entry is added in putSource.

Registering DataSource

void putSource(
  DataSource dataSource,
  boolean allowReplace)

putSource is part of the MutableMetaStore abstraction.

putSource adds the given DataSource to the dataSources registry.

putSource prints out the following INFO message to the logs:

Source [name] created on the metastore

putSource re-builds DROP constraints (if there are any).


Enable ALL logging level for io.confluent.ksql.metastore.MetaStoreImpl logger to see what happens inside.

Add the following line to

Refer to Logging.