kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-1770; clarify descriptive comments of UnknownTopicOrPartitionException; reviewed by Guozhang Wang
Date Fri, 21 Nov 2014 22:26:40 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 457744a82 -> f0fd70929


KAFKA-1770; clarify descriptive comments of UnknownTopicOrPartitionException; reviewed by
Guozhang Wang


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f0fd7092
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f0fd7092
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f0fd7092

Branch: refs/heads/trunk
Commit: f0fd70929a1ad607aa1fbf6ed9b40b16ab95b807
Parents: 457744a
Author: Jiangjie Qin <becket.qin@gmail.com>
Authored: Fri Nov 21 14:25:18 2014 -0800
Committer: Guozhang Wang <guwang@linkedin.com>
Committed: Fri Nov 21 14:25:45 2014 -0800

----------------------------------------------------------------------
 .../scala/kafka/common/UnknownTopicOrPartitionException.scala    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/f0fd7092/core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala b/core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala
index 781e551..f382d16 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. Producer does not have the partition metadata for this id upon sending messages
+ * 2. Broker does not have the specified partition by id upon receiving messages
  */
 class UnknownTopicOrPartitionException(message: String) extends RuntimeException(message)
{
   def this() = this(null)


Mime
View raw message