kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [26/40] git commit: trival change to review unneeded error logging since an exception is already thrown to the caller
Date Thu, 11 Jul 2013 06:37:36 GMT
trival change to review unneeded error logging since an exception is already thrown to the
caller


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

Branch: refs/heads/trunk
Commit: ddb7947c05583ea317e8f994f07b83bf6d5213c3
Parents: 9b30ace
Author: Jun Rao <junrao@gmail.com>
Authored: Sun Jun 9 09:15:17 2013 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Sun Jun 9 09:15:17 2013 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/producer/Producer.scala | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/ddb7947c/core/src/main/scala/kafka/producer/Producer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/producer/Producer.scala b/core/src/main/scala/kafka/producer/Producer.scala
index c837091..bb16a29 100644
--- a/core/src/main/scala/kafka/producer/Producer.scala
+++ b/core/src/main/scala/kafka/producer/Producer.scala
@@ -106,7 +106,6 @@ class Producer[K,V](val config: ProducerConfig,
       if(!added) {
         producerTopicStats.getProducerTopicStats(message.topic).droppedMessageRate.mark()
         producerTopicStats.getProducerAllTopicsStats.droppedMessageRate.mark()
-        error("Event queue is full of unsent messages, could not send event: " + message.toString)
         throw new QueueFullException("Event queue is full of unsent messages, could not send
event: " + message.toString)
       }else {
         trace("Added to send queue an event: " + message.toString)


Mime
View raw message