Hi,

I've read on the message timestamp(KIP-32) that for time-rolling deletes
use LogAppendTime, but this only applies to delete policy.

What timestamp is used when the cleanup policy is _both_ compact+delete?

It would be very useful if it was the timestamp from the record metadata
rather than LogAppendTime or CreateTime as it would of course allow
kafka-backed state stores to simply use the underlying compaction to evict
records based on custom application timestamps and thus have rich ttl
behaviour, that could survive even a full replay of the input stream, etc.

Best,
Michal

Reply via email to