You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2012/02/16 00:51:28 UTC
svn commit: r1244792 -
/incubator/kafka/trunk/core/src/main/scala/kafka/consumer/FetcherRunnable.scala
Author: junrao
Date: Wed Feb 15 23:51:27 2012
New Revision: 1244792
URL: http://svn.apache.org/viewvc?rev=1244792&view=rev
Log:
trivial fix to add trace logging in FetcherRunnable
Modified:
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/FetcherRunnable.scala
Modified: incubator/kafka/trunk/core/src/main/scala/kafka/consumer/FetcherRunnable.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/consumer/FetcherRunnable.scala?rev=1244792&r1=1244791&r2=1244792&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/consumer/FetcherRunnable.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/consumer/FetcherRunnable.scala Wed Feb 15 23:51:27 2012
@@ -58,6 +58,7 @@ class FetcherRunnable(val name: String,
trace("fetch request: " + fetches.toString)
val response = simpleConsumer.multifetch(fetches : _*)
+ trace("recevied response from fetch request: " + fetches.toString)
var read = 0L