Skip to content

Commit 55d3e00

Browse files
committed
Stress that validating - would break compatibility with old cids
1 parent 2a70079 commit 55d3e00

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

  • metadata/src/main/java/org/apache/kafka/metadata/storage

metadata/src/main/java/org/apache/kafka/metadata/storage/Formatter.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -232,7 +232,8 @@ public BootstrapMetadata bootstrapMetadata() {
232232
/**
233233
* Validates the correctness of the given cluster id. A valid cluster id is a base64, urlencoded, no padding
234234
* representation of a {@link Uuid}. These checks do not validate the absence of <code>-</code> character as
235-
* {@link Uuid#randomUuid()} avoids them only for convenience reasons.
235+
* {@link Uuid#randomUuid()} avoids them only for convenience reasons and such a validation would break
236+
* compatibility when attempting to format using an old cluster id.
236237
*/
237238
private void validateClusterId(String clusterId) {
238239
if (clusterId == null) {

0 commit comments

Comments
 (0)