From f45f7ebea458b518577d44e80cf0a9910247d533 Mon Sep 17 00:00:00 2001 From: jqin Date: Fri, 14 Nov 2014 08:56:15 -0800 Subject: [PATCH] Modified doc for UnknownTopicOrPartitionException --- .../main/scala/kafka/common/UnknownTopicOrPartitionException.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala b/core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala index 781e551..4b2e61e 100644 --- a/core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala +++ b/core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala @@ -17,7 +17,9 @@ package kafka.common /** - * Indicates an unknown topic or a partition id not between 0 and numPartitions-1 + * "Indicates one of the following situation: + * 1. Partition id is not between 0 and numPartitions-1 + * 2. Partition id for the topic does not exist on the broker (This could happen when partitions are reassigned)." */ class UnknownTopicOrPartitionException(message: String) extends RuntimeException(message) { def this() = this(null) -- 1.8.3.4 (Apple Git-47)