Import Existing Topics

Importing

See how to import existing topics as a managed asset with Kattlo.

Importing

To import existing topics to Kattlo, run the command bellow:

kattlo \
  --config-file='/path/to/.kattlo.yaml' \
  --kafka-config-file='/path/to/kafka.properties' \
  --bootstrap-servers='my.kafka:9092' \
  topic \
  --directory='/path/to/migrations/for/my/existing/topic' \
  import \
  --topic='my-existing-topic-name'

The operation above will import the existing topic, create the very first migration with create operation and the necessary stuff to enable that topic as a managed asset.

And the file v0001_create-topic.yamlwill be automatically created in the folder defined by --directory option.

Import Existing Topics

Table of contents

Importing