To purge the topic in Kakfa, you can use kafka-configs –entity-type topics. Here’s what it’ll look like:
kafka-configs.sh –zookeeper <zkhost>:2181 –entity-type topics –alter –entity-name <topic name> –add-config retention.ms=1000
Depending on the topic size, you might have to wait for a bit for the purge to complete. But once it’s done, you’ll have to restore the previous value for retention.ms.
Purging stations is pretty easy in Memphis. In addition to the SDK, you can use the trash icon inside the GUI or if you’re using the CLI, you can run the following command:
$ mem station del mystation