Use ConsistentMap (and not the local cache) when querying leader for a topic

Change-Id: I979a4ab116ed68406a6702fe175ba5eab444116c

@@ -219,7 +219,7 @@ public class DistributedLeadershipStore
 
 
     @Override
     @Override
     public Leadership getLeadership(String topic) {
     public Leadership getLeadership(String topic) {
-        InternalLeadership internalLeadership = Versioned.valueOrNull(leadershipCache.get(topic));
+        InternalLeadership internalLeadership = Versioned.valueOrNull(leadershipMap.get(topic));
         return internalLeadership == null ? null : internalLeadership.asLeadership();
         return internalLeadership == null ? null : internalLeadership.asLeadership();
     }
     }