diff --git a/clients/src/main/resources/common/message/BrokerRegistrationRequest.json b/clients/src/main/resources/common/message/BrokerRegistrationRequest.json index ace268db77a6..9343465ec827 100644 --- a/clients/src/main/resources/common/message/BrokerRegistrationRequest.json +++ b/clients/src/main/resources/common/message/BrokerRegistrationRequest.json @@ -59,7 +59,7 @@ { "name": "IsMigratingZkBroker", "type": "bool", "versions": "1+", "default": "false", "about": "If the required configurations for ZK migration are present, this value is set to true" }, { "name": "LogDirs", "type": "[]uuid", "versions": "2+", - "about": "Log directories configured in this broker which are available." }, + "about": "Log directories configured in this broker which are available.", "ignorable": true }, { "name": "PreviousBrokerEpoch", "type": "int64", "versions": "3+", "default": "-1", "ignorable": true, "about": "The epoch before a clean shutdown." } ] diff --git a/clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java b/clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java index b1ecb6aa4b41..4a19a3a16836 100644 --- a/clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java +++ b/clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java @@ -3502,7 +3502,9 @@ private BrokerRegistrationRequest createBrokerRegistrationRequest(short v) { new BrokerRegistrationRequestData.Feature()).iterator())) .setListeners(new BrokerRegistrationRequestData.ListenerCollection(singletonList( new BrokerRegistrationRequestData.Listener()).iterator())) - .setIncarnationId(Uuid.randomUuid()); + .setIncarnationId(Uuid.randomUuid()) + .setLogDirs(Arrays.asList(Uuid.fromString("qaJjNJ05Q36kEgeTBDcj0Q"))) + .setPreviousBrokerEpoch(123L); return new BrokerRegistrationRequest.Builder(data).build(v); }