Skip to main content

metadata_changed_between

Function metadata_changed_between 

Source
pub fn metadata_changed_between(from: i16, to: i16) -> bool
Expand description

Kafka’s MetadataVersion.checkIfMetadataChanged: whether moving between from and to, in either direction, crosses a level that changed the metadata record format. Equal levels never do.

Kafka walks down from the higher level and answers false only when it reaches the lower level without passing a changing level. The lower level itself does not count, because a cluster already at it has its records. A level outside the supported table counts as changing, so a range that leaves the table answers true, as Kafka does when it runs out of predecessors.