Hello everyone, 

I would like to start a discussion on KIP-1282: Prevent data loss during 
partition expansion for dynamically added partitions
<https://cwiki.apache.org/confluence/x/mIY8G>

This proposal aims to introduce a new auto.offset.reset policy by_start_time, 
anchoring the 
offset reset to the consumer's startup timestamp rather than partition 
discovery time, to prevent 
silent data loss during partition expansion.

Best regards,
Jiunn-Yang

Reply via email to