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 2014/05/02 16:45:02 UTC
git commit: kafka-1146;
toString() on KafkaStream gets stuck indefinitely; patched by Arup Malakar;
reviewed by Jun Rao
Repository: kafka
Updated Branches:
refs/heads/trunk 0062d4cc9 -> fe1859549
kafka-1146; toString() on KafkaStream gets stuck indefinitely; patched by Arup Malakar; reviewed by Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/fe185954
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/fe185954
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/fe185954
Branch: refs/heads/trunk
Commit: fe18595492ee91a6a8a796b21c66a682ee9db4a0
Parents: 0062d4c
Author: Arup Malakar <am...@gmail.com>
Authored: Fri May 2 07:44:59 2014 -0700
Committer: Jun Rao <ju...@gmail.com>
Committed: Fri May 2 07:44:59 2014 -0700
----------------------------------------------------------------------
core/src/main/scala/kafka/consumer/KafkaStream.scala | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/fe185954/core/src/main/scala/kafka/consumer/KafkaStream.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/consumer/KafkaStream.scala b/core/src/main/scala/kafka/consumer/KafkaStream.scala
index 31eaf86..805e916 100644
--- a/core/src/main/scala/kafka/consumer/KafkaStream.scala
+++ b/core/src/main/scala/kafka/consumer/KafkaStream.scala
@@ -45,4 +45,7 @@ class KafkaStream[K,V](private val queue: BlockingQueue[FetchedDataChunk],
iter.clearCurrentChunk()
}
+ override def toString(): String = {
+ "%s kafka stream".format(clientId)
+ }
}