Reputation: 1482
I have Debezium in a container, capturing all changes of PostgeSQL database records.
How to delete all kafka topics which are created already and initiate ad-hoc snapshot from the beginning for all tables configured?
Upvotes: 1
Views: 299
Reputation: 191864
You can use kafka-topics --delete
, just like any other topic. The Debezium ones typically match your database schema/table name. You'll also need to find the internal offsets topic created by Kafka Connect framework.
For Docker, though, if you restart Kafka and Zookeeper and they don't have volumes attached, then they'll lose everything, which would be easier for ad-hoc development.
Also, you don't need Zookeeper anymore, as of Kafka 3.3.1
Upvotes: 1