You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@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