Is there a way to purge the topic in Kafka?

by

Temporarily update the retention time on the topic to one second:

kafka-topics.sh \
  --zookeeper <zkhost>:2181 \
  --alter \
  --topic <topic name> \
  --config retention.ms=1000

And in newer Kafka releases, you can also do it with kafka-configs --entity-type topics

kafka-configs.sh \
  --zookeeper <zkhost>:2181 \
  --entity-type topics \
  --alter \
  --entity-name <topic name> \
  --add-config retention.ms=1000

then wait for the purge to take effect (duration depends on size of the topic). Once purged, restore the previous retention.ms value.

More Related Contents:

  1. How to send final kafka-streams aggregation result of a time windowed KTable?
  2. Streamparse wordcount example
  3. Difference between session.timeout.ms and max.poll.interval.ms for Kafka >= 0.10.1
  4. How does an offset expire for an Apache Kafka consumer group?
  5. How to commit manually with Kafka Stream?
  6. Increase the number of messages read by a Kafka consumer in a single poll
  7. Kafka how to read from __consumer_offsets topic
  8. How to change the number of replicas of a Kafka topic?
  9. Delete message after consuming it in KAFKA
  10. Understanding Kafka Topics and Partitions
  11. When to use RabbitMQ over Kafka? [closed]
  12. Delete topic in Kafka 0.8.1.1
  13. Kafka Stream Suppress session-windowed-aggregation
  14. Use Confluent Hub without Confluent Platform installation
  15. How to change start offset for topic?
  16. Kafka 0.11 how to reset offsets
  17. How Can we create a topic in Kafka from the IDE using API
  18. What determines Kafka consumer offset?
  19. How to read records in JSON format from Kafka using Structured Streaming?
  20. Kafka SASL zookeeper authentication
  21. Java, How to get number of messages in a topic in apache kafka
  22. Is it possible to add partitions to an existing topic in Kafka 0.8.2
  23. In Apache Kafka why can’t there be more consumer instances than partitions?
  24. Kafka access inside and outside docker [duplicate]
  25. Why I cannot connect to Kafka from outside?
  26. Handling exceptions in Kafka streams
  27. Is it possible to access message headers with Kafka Streams?
  28. How to get Kafka offsets for structured query for manual and reliable offset management?
  29. Pyspark 2.4.0, read avro from kafka with read stream – Python
  30. How can I delete a topic in Apache Kafka? [duplicate]

Leave a Comment