topic延时问题

来源：4-6 查看Topic列表及Internal杂谈

小麻雀呀

2020-04-28

我创建topic之后，查询listTopic，结果返回没有我刚刚使用代码创建的topic
我上linux使用命令行查询也没有
后面过了1分钟查询，
居然返回了。。。。
老师请问这是啥情况

以下是kafka日志

写回答

2回答

小麻雀呀

提问者

2020-04-28

老师解决了，get阻塞就行了

/**
* 创建topic
*/
public static void createTopic() throws ExecutionException, InterruptedException {
   AdminClient adminClient = adminClient();
   // 创建topic
   NewTopic newTopic = new NewTopic(TOPIC_NAME, 1, Short.valueOf("1"));
   KafkaFuture<Void> all = adminClient.createTopics(Arrays.asList(newTopic)).all();
   all.get();
   if(all.isDone()) {
       System.out.println("创建完成");
   }
}

慕粉1230329569

您好，请教一下，为啥要这么写KafkaFuture all = adminClient.createTopics(Arrays.asList(newTopic)).all(); 最后的 all() 是什么意思？

2022-04-14

共2条回复

小麻雀呀

提问者

2020-04-28

慕课网的提问居然无法显示图片，使用markdown图片标签，我晕，我用的是在线图片地址

//img.mukewang.com/szimg/5ea82b3c0946fe1a22200968.jpg