Hello. I want to start discussion of KIP-870 [1] [2].
The goal of this KIP is to provide new retention policy purely based on record event time. [1] https://cwiki.apache.org/confluence/display/KAFKA/KIP-870%3A+Retention+policy+based+on+record+event+time [2] https://issues.apache.org/jira/browse/KAFKA-13866