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.
