hachikuji commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r952055798
##
server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java:
##
@@ -167,8 +167,18 @@ public enum MetadataVersion {
public static fina
hachikuji commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r952030392
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
hachikuji commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r950502736
##
metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java:
##
@@ -188,12 +182,16 @@ private ApiError updateFeature(
}
}
hachikuji commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r950487364
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1118,6 +1059,65 @@ private void updateWriteOffset(long offset) {
}
}
hachikuji commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r950458081
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1118,6 +1059,65 @@ private void updateWriteOffset(long offset) {
}
}
hachikuji commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r950450852
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
hachikuji commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r95035
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
hachikuji commented on code in PR #12513:
URL: https://github.com/apache/kafka/pull/12513#discussion_r949590579
##
metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapDirectory.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un