[KAFKA-16865] Admin.describeTopics behavior change after KIP-966 - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Task
Status: Resolved
Priority: Major
Resolution: Fixed
Affects Version/s: 3.8.0
Fix Version/s: 3.8.0, 3.9.0
Component/s: admin, clients
Labels:
None

Description

Running the following code produces different behavior between ZooKeeper and KRaft:

DescribeTopicsOptions options = new DescribeTopicsOptions().includeAuthorizedOperations(false);
TopicCollection topics = TopicCollection.ofTopicNames(Collections.singletonList(topic));
DescribeTopicsResult describeTopicsResult = admin.describeTopics(topics, options);
TopicDescription topicDescription = describeTopicsResult.topicNameValues().get(topic).get();
System.out.println(topicDescription.authorizedOperations());

With ZooKeeper this print null, and with KRaft it prints [ALTER, READ, DELETE, ALTER_CONFIGS, CREATE, DESCRIBE_CONFIGS, WRITE, DESCRIBE].

The Admin.getTopicDescriptionFromDescribeTopicsResponseTopic does not take into account the options provided to describeTopics() and always populates the authorizedOperations field.