You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Rudra Moharana <ru...@gmail.com> on 2016/10/14 08:09:27 UTC
Query on kafka queue message purge.
Hi Team,
I need a help for my query
Is there any way to remove the message from kafka queue with out stopping
zookeeper or topic server or cluster.
Thanks,
Rudra
Re: Query on kafka queue message purge.
Posted by David Garcia <da...@spiceworks.com>.
Using the kafka-topics.sh script, simply set the retention in a way to remove the message:
Kafka-topics.sh –zookeeper <zks> --alter –config retention.ms=<ms small enough> --topic <your-topic>
This is actually deprecated, but still works in newer kafka 0.10.0. Note: cleanup=delete is required for this. This policy will only execute when the cleanup thread runs which, by default, is 5 mins.
-David
On 10/14/16, 3:09 AM, "Rudra Moharana" <ru...@gmail.com> wrote:
Hi Team,
I need a help for my query
Is there any way to remove the message from kafka queue with out stopping
zookeeper or topic server or cluster.
Thanks,
Rudra