KIP-20461 — Support Infinite Retention for Consumer Group Offsets

Discussion BrokerConsumer

Allows offsets.retention.minutes to be set to -1, replacing the atLeast(1) validator with one that accepts -1 or any positive integer and short-circuiting OffsetExpirationConditionImpl.isOffsetExpired() so committed offsets never expire. Today only finite values are accepted, so a consumer group whose application crashes unnoticed for longer than the 7-day default is deleted and must fall back to auto.offset.reset on restart, skipping or reprocessing large amounts of data.

Details