non blocking triggerPreferredLeaderElection (#286)

Signed-off-by: Andrew Choi <li_andchoi@microsoft.com>
linkedin · Jun 25, 2020 · 98b525e · 98b525e
1 parent 56b9bf9
commit 98b525e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/linkedin/kmf/services/MultiClusterTopicManagementService.java b/src/main/java/com/linkedin/kmf/services/MultiClusterTopicManagementService.java
@@ -502,7 +502,7 @@ private void triggerPreferredLeaderElection(List<TopicPartitionInfo> partitionIn
       }
       ElectPreferredLeadersResult electPreferredLeadersResult = _adminClient.electPreferredLeaders(partitions);
 
-      LOGGER.info("{}: triggerPreferredLeaderElection - {}", this.getClass().toString(), electPreferredLeadersResult.all().get());
+      LOGGER.info("{}: triggerPreferredLeaderElection - {}", this.getClass().toString(), electPreferredLeadersResult.all());
     }
 
     private static void reassignPartitions(KafkaZkClient zkClient, Collection<Node> brokers, String topic, int partitionCount, int replicationFactor) {