Link Search Menu Expand Document

Import Existing Topics

Table of contents

  1. Importing

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


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

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

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.