Re: Query on kafka queue message purge.

[David Garcia]

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" <rudra...@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