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 2011/09/02 07:19:15 UTC
svn commit: r1164353 - in
/incubator/kafka/trunk/core/src/main/scala/kafka/tools: ConsumerShell.scala
ProducerShell.scala
Author: junrao
Date: Fri Sep 2 05:19:15 2011
New Revision: 1164353
URL: http://svn.apache.org/viewvc?rev=1164353&view=rev
Log:
fix string formatting; write data to stdout in ConsumerShell
Modified:
incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerShell.scala
incubator/kafka/trunk/core/src/main/scala/kafka/tools/ProducerShell.scala
Modified: incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerShell.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerShell.scala?rev=1164353&r1=1164352&r2=1164353&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerShell.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerShell.scala Fri Sep 2 05:19:15 2011
@@ -92,7 +92,7 @@ class ZKConsumerThread(stream: KafkaMess
var count: Int = 0
try {
for (message <- stream) {
- logger.debug("consumed: " + Utils.toString(message.payload, "UTF-8"))
+ println("consumed: " + Utils.toString(message.payload, "UTF-8"))
count += 1
}
}catch {
Modified: incubator/kafka/trunk/core/src/main/scala/kafka/tools/ProducerShell.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/tools/ProducerShell.scala?rev=1164353&r1=1164352&r2=1164353&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/tools/ProducerShell.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/tools/ProducerShell.scala Fri Sep 2 05:19:15 2011
@@ -71,7 +71,7 @@ object ProducerShell {
val lineBytes = line.trim.getBytes()
val messageList = new ByteBufferMessageSet(compressionCodec = NoCompressionCodec, messages = new Message(lineBytes))
producer.send(topic, messageList)
- println("Sent: %d (%ld) bytes)".format(line, messageList.sizeInBytes))
+ println("Sent: %s (%d bytes)".format(line, messageList.sizeInBytes))
}
}
producer.close()