Changed error message

apache · Jun 30, 2021 · efd90cc · efd90cc
1 parent 39f0cba
commit efd90cc
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
@@ -80,7 +80,6 @@
 import org.apache.kafka.common.errors.TimeoutException;
 import org.apache.kafka.common.errors.UnacceptableCredentialException;
 import org.apache.kafka.common.errors.UnknownServerException;
-import org.apache.kafka.common.errors.UnknownTopicIdException;
 import org.apache.kafka.common.errors.UnknownTopicOrPartitionException;
 import org.apache.kafka.common.errors.UnsupportedSaslMechanismException;
 import org.apache.kafka.common.errors.UnsupportedVersionException;
@@ -1734,7 +1733,7 @@ private Map<Uuid, KafkaFuture<Void>> handleDeleteTopicsUsingIds(final Collection
         for (Uuid topicId : topicIds) {
             if (topicId.equals(Uuid.ZERO_UUID)) {
                 KafkaFutureImpl<Void> future = new KafkaFutureImpl<>();
-                future.completeExceptionally(new IllegalArgumentException("The given topic ID '" +
+                future.completeExceptionally(new InvalidTopicException("The given topic ID '" +
                     topicId + "' cannot be represented in a request."));
                 topicFutures.put(topicId, future);
             } else if (!topicFutures.containsKey(topicId)) {