MINOR; Use right enum value for broker registration change (#12236)
The code used BrokerRegistrationFencingChange.FENCE when unfencing a broker and used BrokerRegistrationFencingChange.UNFENCE when fencing a broker, this is confusing. This commit flips the values of the two enums and changes their usage at all of the call sites. Reviewers: José Armando García Sancio <jsancio@users.noreply.github.com>
显示
- metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java 2 个添加, 2 个删除...va/org/apache/kafka/controller/ClusterControlManager.java
- metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java 2 个添加, 2 个删除...rg/apache/kafka/controller/ReplicationControlManager.java
- metadata/src/main/java/org/apache/kafka/image/ClusterDelta.java 2 个添加, 2 个删除...ta/src/main/java/org/apache/kafka/image/ClusterDelta.java
- metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistrationFencingChange.java 2 个添加, 2 个删除...pache/kafka/metadata/BrokerRegistrationFencingChange.java
- metadata/src/test/java/org/apache/kafka/controller/ClusterControlManagerTest.java 3 个添加, 3 个删除...rg/apache/kafka/controller/ClusterControlManagerTest.java
- metadata/src/test/java/org/apache/kafka/metadata/BrokerRegistrationFencingChangeTest.java 4 个添加, 4 个删除...e/kafka/metadata/BrokerRegistrationFencingChangeTest.java
- metadata/src/test/java/org/apache/kafka/metadata/BrokerRegistrationInControlledShutdownChangeTest.java 48 个添加, 0 个删除...ata/BrokerRegistrationInControlledShutdownChangeTest.java
加载中
想要评论请 注册 或 登录