Hello everyone, 

I would like to start a discussion on KIP-1327 Prevent Hot Data Loss on 
Partition Expansion for Latest Policy
<https://cwiki.apache.org/confluence/x/KY4mGQ>

This proposal aims to introduces auto.offset.reset.latest.max.age, a consumer 
config that lets the 
latest reset policy distinguish newly expanded (hot) partitions from 
long-existing (cold) ones. Partitions 
younger than the configured threshold automatically fall back to earliest, 
preventing silent data loss 
during topic expansion without forcing a full historical reprocess.

Best regards,
Jiunn-Yang

Reply via email to