reduce unuseful log

adyliu · Nov 29, 2016 · 2bf229e · 2bf229e
1 parent e75d889
commit 2bf229e
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/src/main/java/io/jafka/consumer/ZookeeperConsumerConnector.java b/src/main/java/io/jafka/consumer/ZookeeperConsumerConnector.java
@@ -710,13 +710,15 @@ private long earliestOrLatestOffset(String topic, int brokerId, int partitionId,
         }
 
         private void releasePartitionOwnership(Pool<String, Pool<Partition, PartitionTopicInfo>> localTopicRegistry) {
-            logger.info("Releasing partition ownership => " + localTopicRegistry.values());
-            for (Map.Entry<String, Pool<Partition, PartitionTopicInfo>> e : localTopicRegistry.entrySet()) {
-                for (Partition partition : e.getValue().keySet()) {
-                    deletePartitionOwnershipFromZK(e.getKey(), partition);
+            if (!localTopicRegistry.isEmpty()) {
+                logger.info("Releasing partition ownership => " + localTopicRegistry.values());
+                for (Map.Entry<String, Pool<Partition, PartitionTopicInfo>> e : localTopicRegistry.entrySet()) {
+                    for (Partition partition : e.getValue().keySet()) {
+                        deletePartitionOwnershipFromZK(e.getKey(), partition);
+                    }
                 }
+                localTopicRegistry.clear();//clear all
             }
-            localTopicRegistry.clear();//clear all
         }
 
         private void deletePartitionOwnershipFromZK(String topic, String partitionStr) {