THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
We will introduce new API methods to AdminClient to describe all topics. New result class "DescribeAllTopicsResult" will be added.
Code Block | ||
---|---|---|
| ||
/** * Describe all topics in the cluster, with the default options. */ public DescribeAllTopicsResult describeTopics() { return describeTopics(new DescribeTopicsOptions()); } /** * Describe all topics in the cluster. * * @return The DescribeAllTopicsResult. */ public abstract DescribeAllTopicsResult describeTopics(DescribeTopicsOptions options); /** * The result of the {@link KafkaAdminClient#describeTopics()} call. */ public class DescribeAllTopicsResult { private final KafkaFuture<Collection<TopicDescription>> future; DescribeAllTopicsResult(KafkaFuture<Collection<TopicDescription>> future) { this.future = future; } public KafkaFuture<Collection<TopicDescription>> value() { return future; } } |
...