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);
}
}
steven