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.
Attachments
Issue Links
- links to