bryanyang0528 / ksql-python

A python wrapper for the KSQL REST API.
MIT License
159 stars 67 forks source link

[Question] How to delete topic ? #84

Closed scheung38 closed 2 years ago

scheung38 commented 4 years ago

Use kafka-topics.sh --delete to delete remove-me topic.

$ ./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic remove-me Topic remove-me is marked for deletion. Note: This will have no impact if delete.topic.enable is not set to true.

But how to do this using this repo?

bryanyang0528 commented 3 years ago

Hi @scheung38, This repo is an API wrapper for KSQL, not Kafka, so this repo can not delete the topic directly unless KSQL API supports this function.