Hi all, I have created KIP-232: Detect outdated metadata by adding ControllerMetadataEpoch field: https://cwiki.apache.org/confluence/display/KAFKA/KIP-232%3A+Detect+outdated+metadata+by+adding+ControllerMetadataEpoch+field .
The KIP proposes to add fields in MetadataResponse and UpdateMetadataRequest so that client can reject outdated metadata and avoid unnecessary OffsetOutOfRangeException. Otherwise there is currently race condition that can cause consumer to reset offset which negatively affect the consumer's availability. Feedback and suggestions are welcome! Regards, Dong
