John, AFAIK not, however, this was suggested as part of the following JIRA: https://issues.apache.org/jira/browse/KAFKA-3726 Feel free to upvote.
– Best regards, Radek Gruchalski ra...@gruchalski.com On October 4, 2016 at 12:17:08 AM, John Vines (jvi...@gmail.com) wrote: Obligatory sorry if I missed it, but I looked at couldn't find anything. Does Kafka support any sort of actions to perform when an event gets truncated due to the retention policy? Background: I'm looking into using kafka to augment our existing rigid data flow by using it as a messaging system, but I'm concerned about systems being unavailable, resulting in persistent data not being cleaned up. I accept the possibility of missed messages with the exception of a 'missed cleanup', so I was hoping for a hook available to use to ensure that at least one action was always available. Thanks John