root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Add entityType for metadata record definitions (#10116) 

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
dengziming 2021-03-10 13:27:06 +08:00 committed by GitHub
parent e6f8f5d0ae
commit 8c9bc9c640
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
35 changed files with 48 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clients/src/main/resources/common/message/AlterIsrRequest.json
View File

@ -33,7 +33,7 @@
"about": "The partition index" },
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The leader epoch of this partition" },
{ "name": "NewIsr", "type": "[]int32", "versions": "0+",
{ "name": "NewIsr", "type": "[]int32", "versions": "0+", "entityType": "brokerId",
"about": "The ISR for this partition"},
{ "name": "CurrentIsrVersion", "type": "int32", "versions": "0+",
"about": "The expected version of ISR which is being updated"}

2
clients/src/main/resources/common/message/AlterIsrResponse.json
View File

@ -36,7 +36,7 @@
"about": "The broker ID of the leader." },
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The leader epoch." },
{ "name": "Isr", "type": "[]int32", "versions": "0+",
{ "name": "Isr", "type": "[]int32", "versions": "0+", "entityType": "brokerId",
"about": "The in-sync replica IDs." },
{ "name": "CurrentIsrVersion", "type": "int32", "versions": "0+",
"about": "The current ISR version." }

2
clients/src/main/resources/common/message/AlterPartitionReassignmentsRequest.json
View File

@ -31,7 +31,7 @@
"about": "The partitions to reassign.", "fields": [
{ "name": "PartitionIndex", "type": "int32", "versions": "0+",
"about": "The partition index." },
{ "name": "Replicas", "type": "[]int32", "versions": "0+", "nullableVersions": "0+", "default": "null",
{ "name": "Replicas", "type": "[]int32", "versions": "0+", "nullableVersions": "0+", "default": "null", "entityType": "brokerId",
"about": "The replicas to place the partitions on, or null to cancel a pending reassignment for this partition." }
]}
]}

2
clients/src/main/resources/common/message/BeginQuorumEpochRequest.json
View File

@ -30,7 +30,7 @@
"versions": "0+", "fields": [
{ "name": "PartitionIndex", "type": "int32", "versions": "0+",
"about": "The partition index." },
{ "name": "LeaderId", "type": "int32", "versions": "0+",
{ "name": "LeaderId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The ID of the newly elected leader"},
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The epoch of the newly elected leader"}

2
clients/src/main/resources/common/message/BeginQuorumEpochResponse.json
View File

@ -30,7 +30,7 @@
{ "name": "PartitionIndex", "type": "int32", "versions": "0+",
"about": "The partition index." },
{ "name": "ErrorCode", "type": "int16", "versions": "0+"},
{ "name": "LeaderId", "type": "int32", "versions": "0+",
{ "name": "LeaderId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The ID of the current leader or -1 if the leader is unknown."},
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The latest known leader epoch"}

2
clients/src/main/resources/common/message/BrokerHeartbeatRequest.json
View File

@ -21,7 +21,7 @@
"validVersions": "0",
"flexibleVersions": "0+",
"fields": [
{ "name": "BrokerId", "type": "int32", "versions": "0+",
{ "name": "BrokerId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The broker ID." },
{ "name": "BrokerEpoch", "type": "int64", "versions": "0+", "default": "-1",
"about": "The broker epoch." },

2
clients/src/main/resources/common/message/BrokerRegistrationRequest.json
View File

@ -21,7 +21,7 @@
"validVersions": "0",
"flexibleVersions": "0+",
"fields": [
{ "name": "BrokerId", "type": "int32", "versions": "0+",
{ "name": "BrokerId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The broker ID." },
{ "name": "ClusterId", "type": "uuid", "versions": "0+",
"about": "The cluster id of the broker process." },

2
clients/src/main/resources/common/message/ConsumerProtocolAssignment.json
View File

@ -25,7 +25,7 @@
"fields": [
{ "name": "AssignedPartitions", "type": "[]TopicPartition", "versions": "0+",
"fields": [
{ "name": "Topic", "type": "string", "mapKey": true, "versions": "0+" },
{ "name": "Topic", "type": "string", "mapKey": true, "versions": "0+", "entityType": "topicName" },
{ "name": "Partitions", "type": "[]int32", "versions": "0+" }
]
},

2
clients/src/main/resources/common/message/ConsumerProtocolSubscription.json
View File

@ -28,7 +28,7 @@
"default": "null", "zeroCopy": true },
{ "name": "OwnedPartitions", "type": "[]TopicPartition", "versions": "1+", "ignorable": true,
"fields": [
{ "name": "Topic", "type": "string", "mapKey": true, "versions": "1+" },
{ "name": "Topic", "type": "string", "mapKey": true, "versions": "1+", "entityType": "topicName" },
{ "name": "Partitions", "type": "[]int32", "versions": "1+"}
]
}

2
clients/src/main/resources/common/message/DeleteTopicsRequest.json
View File

@ -31,7 +31,7 @@
"fields": [
{ "name": "Topics", "type": "[]DeleteTopicState", "versions": "6+", "about": "The name or topic ID of the topic",
"fields": [
{"name": "Name", "type": "string", "versions": "6+", "nullableVersions": "6+", "about": "The topic name"},
{"name": "Name", "type": "string", "versions": "6+", "nullableVersions": "6+", "entityType": "topicName", "about": "The topic name"},
{"name": "TopicId", "type": "uuid", "versions": "6+", "about": "The unique topic ID"}
]},
{ "name": "TopicNames", "type": "[]string", "versions": "0-5", "entityType": "topicName", "ignorable": true,

4
clients/src/main/resources/common/message/DescribeQuorumResponse.json
View File

@ -31,7 +31,7 @@
{ "name": "PartitionIndex", "type": "int32", "versions": "0+",
"about": "The partition index." },
{ "name": "ErrorCode", "type": "int16", "versions": "0+"},
{ "name": "LeaderId", "type": "int32", "versions": "0+",
{ "name": "LeaderId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The ID of the current leader or -1 if the leader is unknown."},
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The latest known leader epoch"},
@ -42,7 +42,7 @@
]}],
"commonStructs": [
{ "name": "ReplicaState", "versions": "0+", "fields": [
{ "name": "ReplicaId", "type": "int32", "versions": "0+"},
{ "name": "ReplicaId", "type": "int32", "versions": "0+", "entityType": "brokerId" },
{ "name": "LogEndOffset", "type": "int64", "versions": "0+",
"about": "The last known log end offset of the follower or -1 if it is unknown"}
]}

2
clients/src/main/resources/common/message/EndQuorumEpochRequest.json
View File

@ -30,7 +30,7 @@
"versions": "0+", "fields": [
{ "name": "PartitionIndex", "type": "int32", "versions": "0+",
"about": "The partition index." },
{ "name": "LeaderId", "type": "int32", "versions": "0+",
{ "name": "LeaderId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The current leader ID that is resigning"},
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The current epoch"},

2
clients/src/main/resources/common/message/EndQuorumEpochResponse.json
View File

@ -30,7 +30,7 @@
{ "name": "PartitionIndex", "type": "int32", "versions": "0+",
"about": "The partition index." },
{ "name": "ErrorCode", "type": "int16", "versions": "0+"},
{ "name": "LeaderId", "type": "int32", "versions": "0+",
{ "name": "LeaderId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The ID of the current leader or -1 if the leader is unknown."},
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The latest known leader epoch"}

2
clients/src/main/resources/common/message/FetchRequest.json
View File

@ -53,7 +53,7 @@
{ "name": "ClusterId", "type": "string", "versions": "12+", "nullableVersions": "12+", "default": "null",
"taggedVersions": "12+", "tag": 0, "ignorable": true,
"about": "The clusterId if known. This is used to validate metadata fetches prior to broker registration." },
{ "name": "ReplicaId", "type": "int32", "versions": "0+",
{ "name": "ReplicaId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The broker ID of the follower, of -1 if this request is from a consumer." },
{ "name": "MaxWaitMs", "type": "int32", "versions": "0+",
"about": "The maximum time in milliseconds to wait for the response." },

4
clients/src/main/resources/common/message/FetchResponse.json
View File

@ -73,7 +73,7 @@
]},
{ "name": "CurrentLeader", "type": "LeaderIdAndEpoch",
"versions": "12+", "taggedVersions": "12+", "tag": 1, "fields": [
{ "name": "LeaderId", "type": "int32", "versions": "12+", "default": "-1",
{ "name": "LeaderId", "type": "int32", "versions": "12+", "default": "-1", "entityType": "brokerId",
"about": "The ID of the current leader or -1 if the leader is unknown."},
{ "name": "LeaderEpoch", "type": "int32", "versions": "12+", "default": "-1",
"about": "The latest known leader epoch"}
@ -92,7 +92,7 @@
{ "name": "FirstOffset", "type": "int64", "versions": "4+",
"about": "The first offset in the aborted transaction." }
]},
{ "name": "PreferredReadReplica", "type": "int32", "versions": "11+", "default": "-1", "ignorable": false,
{ "name": "PreferredReadReplica", "type": "int32", "versions": "11+", "default": "-1", "ignorable": false, "entityType": "brokerId",
"about": "The preferred read replica for the consumer to use on its next fetch request"},
{ "name": "Records", "type": "records", "versions": "0+", "nullableVersions": "0+", "about": "The record data."}
]}

2
clients/src/main/resources/common/message/FetchSnapshotRequest.json
View File

@ -23,7 +23,7 @@
"fields": [
{ "name": "ClusterId", "type": "string", "versions": "0+", "nullableVersions": "0+", "default": "null", "taggedVersions": "0+", "tag": 0,
"about": "The clusterId if known, this is used to validate metadata fetches prior to broker registration" },
{ "name": "ReplicaId", "type": "int32", "versions": "0+", "default": "-1",
{ "name": "ReplicaId", "type": "int32", "versions": "0+", "default": "-1", "entityType": "brokerId",
"about": "The broker ID of the follower" },
{ "name": "MaxBytes", "type": "int32", "versions": "0+", "default": "0x7fffffff",
"about": "The maximum bytes to fetch from all of the snapshots" },

2
clients/src/main/resources/common/message/FetchSnapshotResponse.json
View File

@ -42,7 +42,7 @@
]},
{ "name": "CurrentLeader", "type": "LeaderIdAndEpoch",
"versions": "0+", "taggedVersions": "0+", "tag": 0, "fields": [
{ "name": "LeaderId", "type": "int32", "versions": "0+",
{ "name": "LeaderId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The ID of the current leader or -1 if the leader is unknown."},
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The latest known leader epoch"}

2
clients/src/main/resources/common/message/InitProducerIdRequest.json
View File

@ -32,7 +32,7 @@
"about": "The transactional id, or null if the producer is not transactional." },
{ "name": "TransactionTimeoutMs", "type": "int32", "versions": "0+",
"about": "The time in ms to wait before aborting idle transactions sent by this producer. This is only relevant if a TransactionalId has been defined." },
{ "name": "ProducerId", "type": "int64", "versions": "3+", "default": "-1",
{ "name": "ProducerId", "type": "int64", "versions": "3+", "default": "-1", "entityType": "producerId",
"about": "The producer id. This is used to disambiguate requests if a transactional id is reused following its expiration." },
{ "name": "ProducerEpoch", "type": "int16", "versions": "3+", "default": "-1",
"about": "The producer's current epoch. This will be checked against the producer epoch on the broker, and the request will return an error if they do not match." }

8
clients/src/main/resources/common/message/LeaderAndIsrRequest.json
View File

@ -74,15 +74,15 @@
"about": "The broker ID of the leader." },
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The leader epoch." },
{ "name": "Isr", "type": "[]int32", "versions": "0+",
{ "name": "Isr", "type": "[]int32", "versions": "0+", "entityType": "brokerId",
"about": "The in-sync replica IDs." },
{ "name": "ZkVersion", "type": "int32", "versions": "0+",
"about": "The ZooKeeper version." },
{ "name": "Replicas", "type": "[]int32", "versions": "0+",
{ "name": "Replicas", "type": "[]int32", "versions": "0+", "entityType": "brokerId",
"about": "The replica IDs." },
{ "name": "AddingReplicas", "type": "[]int32", "versions": "3+", "ignorable": true,
{ "name": "AddingReplicas", "type": "[]int32", "versions": "3+", "ignorable": true, "entityType": "brokerId",
"about": "The replica IDs that we are adding this partition to, or null if no replicas are being added." },
{ "name": "RemovingReplicas", "type": "[]int32", "versions": "3+", "ignorable": true,
{ "name": "RemovingReplicas", "type": "[]int32", "versions": "3+", "ignorable": true, "entityType": "brokerId",
"about": "The replica IDs that we are removing this partition from, or null if no replicas are being removed." },
{ "name": "IsNew", "type": "bool", "versions": "1+", "default": "false", "ignorable": true,
"about": "Whether the replica should have existed on the broker or not." }

2
clients/src/main/resources/common/message/LeaderChangeMessage.json
View File

@ -19,7 +19,7 @@
"validVersions": "0",
"flexibleVersions": "0+",
"fields": [
{"name": "LeaderId", "type": "int32", "versions": "0+",
{"name": "LeaderId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The ID of the newly elected leader"},
{"name": "Voters", "type": "[]Voter", "versions": "0+",
"about": "The set of voters in the quorum for this epoch"},

6
clients/src/main/resources/common/message/ListPartitionReassignmentsResponse.json
View File

@ -34,11 +34,11 @@
"about": "The ongoing reassignments for each partition.", "fields": [
{ "name": "PartitionIndex", "type": "int32", "versions": "0+",
"about": "The index of the partition." },
{ "name": "Replicas", "type": "[]int32", "versions": "0+",
{ "name": "Replicas", "type": "[]int32", "versions": "0+", "entityType": "brokerId",
"about": "The current replica set." },
{ "name": "AddingReplicas", "type": "[]int32", "versions": "0+",
{ "name": "AddingReplicas", "type": "[]int32", "versions": "0+", "entityType": "brokerId",
"about": "The set of replicas we are currently adding." },
{ "name": "RemovingReplicas", "type": "[]int32", "versions": "0+",
{ "name": "RemovingReplicas", "type": "[]int32", "versions": "0+", "entityType": "brokerId",
"about": "The set of replicas we are currently removing." }
]}
]}

2
clients/src/main/resources/common/message/ListTransactionsRequest.json
View File

@ -24,7 +24,7 @@
{ "name": "StateFilters", "type": "[]string", "versions": "0+",
"about": "The transaction states to filter by: if empty, all transactions are returned; if non-empty, then only transactions matching one of the filtered states will be returned"
},
{ "name": "ProducerIdFilters", "type": "[]int64", "versions": "0+",
{ "name": "ProducerIdFilters", "type": "[]int64", "versions": "0+", "entityType": "producerId",
"about": "The producerIds to filter by: if empty, all transactions will be returned; if non-empty, only transactions which match one of the filtered producerIds will be returned"
}
]

4
clients/src/main/resources/common/message/MetadataResponse.json
View File

@ -82,9 +82,9 @@
"about": "The leader epoch of this partition." },
{ "name": "ReplicaNodes", "type": "[]int32", "versions": "0+", "entityType": "brokerId",
"about": "The set of all nodes that host this partition." },
{ "name": "IsrNodes", "type": "[]int32", "versions": "0+",
{ "name": "IsrNodes", "type": "[]int32", "versions": "0+", "entityType": "brokerId",
"about": "The set of nodes that are in sync with the leader for this partition." },
{ "name": "OfflineReplicas", "type": "[]int32", "versions": "5+", "ignorable": true,
{ "name": "OfflineReplicas", "type": "[]int32", "versions": "5+", "ignorable": true, "entityType": "brokerId",
"about": "The set of offline replicas of this partition." }
]},
{ "name": "TopicAuthorizedOperations", "type": "int32", "versions": "8+", "default": "-2147483648",

2
clients/src/main/resources/common/message/OffsetForLeaderEpochRequest.json
View File

@ -30,7 +30,7 @@
"validVersions": "0-4",
"flexibleVersions": "4+",
"fields": [
{ "name": "ReplicaId", "type": "int32", "versions": "3+", "default": -2, "ignorable": true,
{ "name": "ReplicaId", "type": "int32", "versions": "3+", "default": -2, "ignorable": true, "entityType": "brokerId",
"about": "The broker ID of the follower, of -1 if this request is from a consumer." },
{ "name": "Topics", "type": "[]OffsetForLeaderTopic", "versions": "0+",
"about": "Each topic to get offsets for.", "fields": [

2
clients/src/main/resources/common/message/UnregisterBrokerRequest.json
View File

@ -21,7 +21,7 @@
"validVersions": "0",
"flexibleVersions": "0+",
"fields": [
{ "name": "BrokerId", "type": "int32", "versions": "0+",
{ "name": "BrokerId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The broker ID to unregister." }
]
}

2
clients/src/main/resources/common/message/UpdateFeaturesResponse.json
View File

@ -28,7 +28,7 @@
"about": "The top-level error message, or `null` if there was no top-level error." },
{ "name": "Results", "type": "[]UpdatableFeatureResult", "versions": "0+",
"about": "Results for each feature update.", "fields": [
{"name": "Feature", "type": "string", "versions": "0+", "mapKey": true,
{ "name": "Feature", "type": "string", "versions": "0+", "mapKey": true,
"about": "The name of the finalized feature."},
{ "name": "ErrorCode", "type": "int16", "versions": "0+",
"about": "The feature update error code or `0` if the feature update succeeded." },

2
clients/src/main/resources/common/message/VoteRequest.json
View File

@ -33,7 +33,7 @@
"about": "The partition index." },
{ "name": "CandidateEpoch", "type": "int32", "versions": "0+",
"about": "The bumped epoch of the candidate sending the request"},
{ "name": "CandidateId", "type": "int32", "versions": "0+",
{ "name": "CandidateId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The ID of the voter sending the request"},
{ "name": "LastOffsetEpoch", "type": "int32", "versions": "0+",
"about": "The epoch of the last record written to the metadata log"},

2
clients/src/main/resources/common/message/VoteResponse.json
View File

@ -31,7 +31,7 @@
{ "name": "PartitionIndex", "type": "int32", "versions": "0+",
"about": "The partition index." },
{ "name": "ErrorCode", "type": "int16", "versions": "0+"},
{ "name": "LeaderId", "type": "int32", "versions": "0+",
{ "name": "LeaderId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The ID of the current leader or -1 if the leader is unknown."},
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+",
"about": "The latest known leader epoch"},

2
metadata/src/main/resources/common/metadata/FenceBrokerRecord.json
View File

@ -19,7 +19,7 @@
"name": "FenceBrokerRecord",
"validVersions": "0",
"fields": [
{ "name": "Id", "type": "int32", "versions": "0+",
{ "name": "Id", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The broker ID to fence. It will be removed from all ISRs." },
{ "name": "Epoch", "type": "int64", "versions": "0+",
"about": "The epoch of the broker to fence." }

6
metadata/src/main/resources/common/metadata/PartitionChangeRecord.json
View File

@ -24,10 +24,10 @@
"about": "The partition id." },
{ "name": "TopicId", "type": "uuid", "versions": "0+",
"about": "The unique ID of this topic." },
{ "name": "Isr", "type": "[]int32", "default": "null",
"versions": "0+", "nullableVersions": "0+", "taggedVersions": "0+", "tag": 0,
{ "name": "Isr", "type": "[]int32", "default": "null", "entityType": "brokerId",
"versions": "0+", "nullableVersions": "0+", "taggedVersions": "0+", "tag": 0,
"about": "null if the ISR didn't change; the new in-sync replicas otherwise." },
{ "name": "Leader", "type": "int32", "default": "-2",
{ "name": "Leader", "type": "int32", "default": "-2", "entityType": "brokerId",
"versions": "0+", "taggedVersions": "0+", "tag": 1,
"about": "-1 if there is now no leader; -2 if the leader didn't change; the new leader otherwise." }
]

8
metadata/src/main/resources/common/metadata/PartitionRecord.json
View File

@ -23,15 +23,15 @@
"about": "The partition id." },
{ "name": "TopicId", "type": "uuid", "versions": "0+",
"about": "The unique ID of this topic." },
{ "name": "Replicas", "type": "[]int32", "versions": "0+",
{ "name": "Replicas", "type": "[]int32", "versions": "0+", "entityType": "brokerId",
"about": "The replicas of this partition, sorted by preferred order." },
{ "name": "Isr", "type": "[]int32", "versions": "0+",
"about": "The in-sync replicas of this partition" },
{ "name": "RemovingReplicas", "type": "[]int32", "versions": "0+", "nullableVersions": "0+",
{ "name": "RemovingReplicas", "type": "[]int32", "versions": "0+", "nullableVersions": "0+", "entityType": "brokerId",
"about": "The replicas that we are in the process of removing." },
{ "name": "AddingReplicas", "type": "[]int32", "versions": "0+", "nullableVersions": "0+",
{ "name": "AddingReplicas", "type": "[]int32", "versions": "0+", "nullableVersions": "0+", "entityType": "brokerId",
"about": "The replicas that we are in the process of adding." },
{ "name": "Leader", "type": "int32", "versions": "0+", "default": "-1",
{ "name": "Leader", "type": "int32", "versions": "0+", "default": "-1", "entityType": "brokerId",
"about": "The lead replica, or -1 if there is no leader." },
{ "name": "LeaderEpoch", "type": "int32", "versions": "0+", "default": "-1",
"about": "The epoch of the partition leader." },

2
metadata/src/main/resources/common/metadata/RegisterBrokerRecord.json
View File

@ -19,7 +19,7 @@
"name": "RegisterBrokerRecord",
"validVersions": "0",
"fields": [
{ "name": "BrokerId", "type": "int32", "versions": "0+",
{ "name": "BrokerId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The broker id." },
{ "name": "IncarnationId", "type": "uuid", "versions": "0+",
"about": "The incarnation ID of the broker process" },

2
metadata/src/main/resources/common/metadata/TopicRecord.json
View File

@ -19,7 +19,7 @@
"name": "TopicRecord",
"validVersions": "0",
"fields": [
{ "name": "Name", "type": "string", "versions": "0+",
{ "name": "Name", "type": "string", "versions": "0+", "entityType": "topicName",
"about": "The topic name." },
{ "name": "TopicId", "type": "uuid", "versions": "0+",
"about": "The unique ID of this topic." }

2
metadata/src/main/resources/common/metadata/UnfenceBrokerRecord.json
View File

@ -19,7 +19,7 @@
"name": "UnfenceBrokerRecord",
"validVersions": "0",
"fields": [
{ "name": "Id", "type": "int32", "versions": "0+",
{ "name": "Id", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The broker ID to unfence." },
{ "name": "Epoch", "type": "int64", "versions": "0+",
"about": "The epoch of the broker to unfence." }

2
metadata/src/main/resources/common/metadata/UnregisterBrokerRecord.json
View File

@ -19,7 +19,7 @@
"name": "UnregisterBrokerRecord",
"validVersions": "0",
"fields": [
{ "name": "BrokerId", "type": "int32", "versions": "0+",
{ "name": "BrokerId", "type": "int32", "versions": "0+", "entityType": "brokerId",
"about": "The broker id." },
{ "name": "BrokerEpoch", "type": "int64", "versions": "0+",
"about": "The broker epoch." }