gabriellefu commented on code in PR #22213:
URL: https://github.com/apache/kafka/pull/22213#discussion_r3228914309
##########
clients/src/main/resources/common/message/StreamsGroupHeartbeatResponse.json:
##########
@@ -52,6 +52,8 @@
"about": "The maximal lag a warm-up task can have to be considered
caught-up." },
{ "name": "TaskOffsetIntervalMs", "type": "int32", "versions": "0+",
"about": "The interval in which the task changelog offsets on a client
are updated on the broker. The offsets are sent with the next heartbeat after
this time has passed." },
+ { "name": "RackAwareAssignmentTags", "type": "[]string", "versions": "0+",
"nullableVersions": "0+", "default": "null",
+ "about": "The list of client tag keys used for rack-aware standby task
assignment. Null if unchanged since last heartbeat." },
Review Comment:
Since we changed "sending broker's tags to client and let client do the
validation" to "broker do the validation and send a status if some tags are
missing", this is not applied anymore.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
