@ConcurrencyPractitioner . Ah, good question. TaskMetadata is upgradeable. All we need to do is add new "bits" of metadata to the class definition, and make sure that they have reasonable "unknown" default values. We'll need to add new versions to the assignment protocol, just because the binary schema would be different, and the older versions would just set the default values for metadata "bits" that aren't part of their protocol.
[ Full content available at: https://github.com/apache/kafka/pull/5012 ] This message was relayed via gitbox.apache.org for [email protected]
