Hi, Kafka supports two types of log/messages retention policies.
Log retention(size/time): The messages will be discarded after log.retention.minutes or when the log size reaches log.retention.bytes Log compaction: which ensures that Kafka will always retain at least the last known value for each message key within the log of data for a single topic partition. https://kafka.apache.org/documentation.html#compaction Kumar On Fri, Aug 1, 2014 at 4:02 PM, anand jain <anandjain1...@gmail.com> wrote: > I want to delete the message from a Kafka broker after consuming it(Java > consumer). How can I do that? >
