@RequestMapping(value = "/getTopics",method = RequestMethod.GET)
@ResponseBody
public Response getAllTopics() {
ZkClient zkClient = new ZkClient(ZookeeperProps.zookeeperURL, ZookeeperProps.connectionTimeoutMs,
ZookeeperProps.sessionTimeoutMs, ZKStringSerializer$.MODULE$);
Seq<String> topics = ZkUtils.getAllTopics(zkClient);
scala.collection.Iterator<String> topicIterator = topics.iterator();
String allTopics = "";
while(topicIterator.hasNext()) {
allTopics+=topicIterator.next();
allTopics+="\n";
}
Response response = new Response();
response.setResponseMessage(allTopics);
return response;
}
我是apache kafka的新手。 現在有一段時間想與動物園管理員瞭解卡夫卡。 我想獲取與zookeeper相關的主題。所以我想下面的東西
了:)首先,我所做的動物園管理員客戶端,如下圖所示:如何獲得apache kafka中的所有主題?
ZkClient(ZookeeperProps.zookeeperURL, ZookeeperProps.connectionTimeoutMs, ZookeeperProps.sessionTimeoutMs, ZKStringSerializer$.MODULE$);
Seq<String> topics = ZkUtils.getAllTopics(zkClient);
,但主題是空集,而與Java code.I執行我不是得到什麼這裏是問題。 我的Zookeeper道具如下:String zkConnect =「127.0.0.1:2181」; 動物園管理員運行得很好。
請幫助球員。
請人幫助我。 – psan