关于Java代码创建topic的问题

来源：4-5 创建Topic演示

精慕门6573819

2020-04-13

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。

写回答

1回答