jolshan commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r546862700
##########
File path: clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
##########
@@ -287,7 +288,23 @@ default DescribeTopicsResult
describeTopics(Collection<String> topicNames) {
* @param options The options to use when describing the topic.
* @return The DescribeTopicsResult.
*/
- DescribeTopicsResult describeTopics(Collection<String> topicNames,
DescribeTopicsOptions options);
+ DescribeTopicsResult<String> describeTopics(Collection<String> topicNames,
DescribeTopicsOptions options);
+
+ /**
+ * Describe some topics in the cluster by their topicId, with the default
options.
+ * <p>
+ * This is a convenience method for {@link
#describeTopicsWithIds(Collection, DescribeTopicsOptions)} with
+ * default options. See the overload for more details.
+ *
+ * @param topicIds The topicIds of the topics to describe.
+ * @return The DescribeTopicsResult.
+ */
+ default DescribeTopicsResult<Uuid> describeTopicsWithIds(Collection<Uuid>
topicIds) {
+ return describeTopicsWithIds(topicIds, new DescribeTopicsOptions());
+ }
+
+ DescribeTopicsResult<Uuid> describeTopicsWithIds(Collection<Uuid>
topicIds, DescribeTopicsOptions options);
Review comment:
nit: javadoc comment missing
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
