From a41f8cbd735d56a8d5c4939e7037369f05bb55db Mon Sep 17 00:00:00 2001 From: jqin Date: Wed, 3 Jun 2015 13:23:33 -0700 Subject: [PATCH] Change UnknownTopicOrPartitionException to extends InvalidMetadataException. --- .../apache/kafka/common/errors/UnknownTopicOrPartitionException.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java b/clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java index ec423bd..70fd55c 100644 --- a/clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java +++ b/clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java @@ -15,7 +15,7 @@ package org.apache.kafka.common.errors; /** * This topic/partition doesn't exist */ -public class UnknownTopicOrPartitionException extends RetriableException { +public class UnknownTopicOrPartitionException extends InvalidMetadataException { private static final long serialVersionUID = 1L; -- 1.8.3.4 (Apple Git-47)