Using the script, simply set the retention in a way to remove 
the message: –zookeeper <zks> --alter –config<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.


On 10/14/16, 3:09 AM, "Rudra Moharana" <> 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.

Reply via email to