kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1146; toString() on KafkaStream gets stuck indefinitely; patched by Arup Malakar; reviewed by Jun Rao
Date Fri, 02 May 2014 14:45:02 GMT
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 <amalakar@gmail.com>
Authored: Fri May 2 07:44:59 2014 -0700
Committer: Jun Rao <junrao@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)
+  }
 }


Mime
View raw message