kafka flush all messages code example
Example: remove all data from kafka topic
kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic1 --config retention.ms=1000
kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic1 --config retention.ms=1000