Using the kafka-topics.sh script, simply set the retention in a way to remove
Kafka-topics.sh –zookeeper <zks> --alter –config retention.ms=<ms small enough>
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" <rudra...@gmail.com> wrote:
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.