import org.apache.solr.client.solrj.impl.CloudSolrServer;
       import org.apache.solr.common.cloud.ZkStateReader;

       import org.apache.solr.common.cloud.ZkStateReader;
       import org.apache.zookeeper.KeeperException;
       import java.net.MalformedURLException;
       import java.lang.System;


       String zkHost = "host1:8080,host2:8080,host3:8080";

        CloudSolrServer server = null;
        try {
            server = new CloudSolrServer(zkHost);
            System.out.println("try");
        } catch (MalformedURLException e) {
            // TODO Auto-generated catch block
            System.out.println("error");
            e.printStackTrace();
        }
        //Then,  set a default collection.
        String defaultCollection = "my_collection";

        server.setDefaultCollection(defaultCollection);

        //Then, set a connection timeout
        int zkClientTimeout = 1000;
        server.setZkClientTimeout(zkClientTimeout);

        //Then, connect to zookeeper.
        //server.connect();

        //Then, get a ZkStateReader object.
        ZkStateReader zkStateReader = server.getZkStateReader();

        //Then, get the URL for the leader node.
        String shard = "shard1";
        String leaderUrl = null;
        try {
            leaderUrl = zkStateReader.getLeaderUrl(defaultCollection, shard, zkClientTimeout);
            System.out.println(leaderUrl);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (KeeperException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        System.out.println(leaderUrl);