[KAFKA-7808] AdminClient#describeTopics should not throw InvalidTopicException if topic name is not found

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.2.0
• Component/s: admin, core
• Assignee: Dongjin Lee
• Reporter: Guozhang Wang
• Created: 09/Jan/19 20:54
• Updated: 14/Jan/19 17:16
• Resolved: 14/Jan/19 17:16

Description

In AdminClient#describeTopics, we have the following logic:

        if (!cluster.topics().contains(topicName)) {
                        future.completeExceptionally(new InvalidTopicException("Topic " + topicName + " not found."));
                        continue;
                    }

However, InvalidTopicException is a non-retriable exception and is used to indicate that topic contains invalid chars or topic name is too long etc, and hence not correct to use. We should, instead, throw the retriable UnknownTopicOrPartitionException instead.

We should make sure any callers on this logic should be cleaned up when fixing it.

Issue Links

• links to: GitHub Pull Request #6124