解决createTopics无法创建topic

来源：4-5 创建Topic演示

jeonsu

2020-06-25

以下两种方法都可以

    public static void creatTopic() {
        AdminClient adminClient = adminClient();
        // 副本因子
        short re = 1;
        NewTopic newTopic = new NewTopic(TOPIC_NAME, 1, re);
        CreateTopicsResult topics = adminClient.createTopics(Arrays.asList(newTopic));

        // 方法一
        try {
            topics.all().get();
        } catch (Exception e) {
            e.printStackTrace();
        }
        // 方法二
//        while (!topics.all().isDone()) {
//        }
        System.out.println("CreateTopicsResult: " + topics.values());
    }

写回答

1回答