Updated Branches: refs/heads/0.8 9b30aceea -> ddb7947c0
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/0.8 Commit: ddb7947c05583ea317e8f994f07b83bf6d5213c3 Parents: 9b30ace Author: Jun Rao <jun...@gmail.com> Authored: Sun Jun 9 09:15:17 2013 -0700 Committer: Jun Rao <jun...@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)
