revert unnecessary change

TaiJuWu · Feb 4, 2025 · f023b99 · f023b99
1 parent 8551754
commit f023b99
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
@@ -1138,7 +1138,7 @@ private void initiateConnect(Node node, long now) {
         try {
             connectionStates.connecting(nodeConnectionId, now, node.host());
             InetAddress address = connectionStates.currentAddress(nodeConnectionId);
-            log.error("KKK Initiating connection to node {} using address {}", node, address);
+            log.debug("Initiating connection to node {} using address {}", node, address);
             selector.connect(nodeConnectionId,
                     new InetSocketAddress(address, node.port()),
                     this.socketSendBuffer,

diff --git a/raft/src/main/java/org/apache/kafka/raft/QuorumState.java b/raft/src/main/java/org/apache/kafka/raft/QuorumState.java
@@ -336,6 +336,7 @@ public boolean isVoter() {
         if (localId.isEmpty()) {
             return false;
         }
+
         return partitionState
             .lastVoterSet()
             .isVoter(ReplicaKey.of(localId.getAsInt(), localDirectoryId));