Ewen Cheslack-Postava <ewen@...> writes:

Im also searching the shortest way to find topic partition count, so that the 
initialization code in the thread pool can set up the right number of threads.

so far i found below is the shortest way. 


        public static void main(String[] args){
                
                int sessionTimeoutMs = 10000;
                int connectionTimeoutMs = 10000;
                ZkClient zkClient = new ZkClient("localhost:2181", 
sessionTimeoutMs, connectionTimeoutMs);

                TopicMetadata metaData =  
AdminUtils.fetchTopicMetadataFromZk("forthtopic",zkClient);
                System.out.println(metaData.partitionsMetadata().size());

        }

kindly reply if you find any other shortest way.




Reply via email to