[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-22 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r580411938 ## File path: metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java ## @@ -0,0 +1,136 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-19 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r578003900 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -0,0 +1,920 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-19 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r578065045 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -0,0 +1,920 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-19 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r579553251 ## File path: metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java ## @@ -0,0 +1,908 @@ +/* + * Licensed to the Apache

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-19 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r579538752 ## File path: metadata/src/main/resources/common/metadata/PartitionRecord.json ## @@ -34,6 +34,8 @@ { "name": "Leader", "type": "int32", "versions":

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-19 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r579497748 ## File path: metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java ## @@ -0,0 +1,894 @@ +/* + * Licensed to the Apache

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-19 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r579496903 ## File path: metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java ## @@ -0,0 +1,894 @@ +/* + * Licensed to the Apache

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-19 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r579438984 ## File path: metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java ## @@ -0,0 +1,894 @@ +/* + * Licensed to the Apache

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-19 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r579411851 ## File path: metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java ## @@ -0,0 +1,894 @@ +/* + * Licensed to the Apache

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-18 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r578876029 ## File path: metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java ## @@ -0,0 +1,341 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-18 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r578851481 ## File path: metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java ## @@ -0,0 +1,136 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-18 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r578693886 ## File path: metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java ## @@ -0,0 +1,136 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-18 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r578065045 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -0,0 +1,920 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-18 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r578003900 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -0,0 +1,920 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-17 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r577879960 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -0,0 +1,917 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-16 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r577278241 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -0,0 +1,920 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-16 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r577268593 ## File path: metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java ## @@ -0,0 +1,456 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-16 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r577263866 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -0,0 +1,920 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-16 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r577262652 ## File path: metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java ## @@ -0,0 +1,712 @@ +/* + * Licensed to the Apache

[GitHub] [kafka] junrao commented on a change in pull request #10070: KAFKA-12276: Add the quorum controller code

2021-02-16 Thread GitBox
junrao commented on a change in pull request #10070: URL: https://github.com/apache/kafka/pull/10070#discussion_r577259797 ## File path: metadata/src/main/java/org/apache/kafka/controller/QuorumController.java ## @@ -0,0 +1,920 @@ +/* + * Licensed to the Apache Software