0
点赞
收藏
分享

微信扫一扫

2.3 Kafka Admin API之查询主题


1.代码示例

public class AdminSample {
private static final String topicName = "steven";

private static final int partitionNumber = 1;

private static final Short replicationFactor = 1;

/**
* 创建AdminClient
*/
public static AdminClient adminClient() {
Properties properties = new Properties();
properties.setProperty(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "127.0.0.1:9092");
AdminClient adminClient = AdminClient.create(properties);
return adminClient;
}

/**
* 获取topic列表
*/
public static void main(String[] args) throws ExecutionException, InterruptedException {
AdminClient adminClient = AdminSample.adminClient();
ListTopicsResult listTopicsResult = adminClient.listTopics();
Set<String> names = listTopicsResult.names().get();
names.stream().forEach(System.out::println);
}
}

2.代码运行结果

steven


举报

相关推荐

0 条评论