关于Java代码创建topic的问题

Question

public static void createTopic(){
        AdminClient adminClient = adminClient();
        short rs = 1;
        NewTopic newTopic = new NewTopic(TOPIC_NAME,1,rs);
        CreateTopicsResult topics = adminClient.createTopics(Arrays.asList(newTopic));
        System.out.println("CreateTopicsResult:"+topics);
    }

请问老师我这段创建topic的代码无法成功创建topic，控制台没有任何报错。使用命令行创建topic没问题，java代码中查询topic列表可以查出使用命令行创建的topic。

Answer 1

Allen 2020-04-14 09:57:22

没有连接超时是吧。 那应该问题不大， 不过创建Topic是会有延迟的， 创建以后可以稍微等一会再确认。 另外去看一下日志目录下是否有对应的partition目录

• 孤独观测者 #1

  老师我也是代码创建topic的时候没有成功，显示Queueing Call(callName=createTopics, deadlineMs=1586849979248) with a timeout 120000 ms from now.
  应该是超时了

• Allen 回复 孤独观测者 #2

  错误截个图呗

• wesays 回复 孤独观测者 #3

  超时怎么解决

点开查看后面1条评论