kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject svn commit: r1410588 - in /incubator/kafka/branches/0.8/core/src/main/scala/kafka: javaapi/producer/ProducerData.scala tools/KafkaMigrationTool.java
Date Fri, 16 Nov 2012 21:55:37 GMT
Author: jkreps
Date: Fri Nov 16 21:55:36 2012
New Revision: 1410588

URL: http://svn.apache.org/viewvc?rev=1410588&view=rev
Log:
KAFKA-544 Trivial fix--migration tool is using message when it should be using a byte array.
Checked in w/o review.

Removed:
    incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/producer/ProducerData.scala
Modified:
    incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/KafkaMigrationTool.java

Modified: incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/KafkaMigrationTool.java
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/KafkaMigrationTool.java?rev=1410588&r1=1410587&r2=1410588&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/KafkaMigrationTool.java (original)
+++ incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/KafkaMigrationTool.java Fri
Nov 16 21:55:36 2012
@@ -280,9 +280,8 @@ public class KafkaMigrationTool
           int size = ((ByteBuffer)payload_07).remaining();
           byte[] bytes = new byte[size];
           ((ByteBuffer)payload_07).get(bytes);
-          Message message_08 = new Message(bytes);
-          logger.debug(String.format("Send kafka 08 message of size %d to topic %s", message_08.size(),
topic));
-          KeyedMessage<String, Message> producerData = new KeyedMessage((String)topic,
null, message_08);
+          logger.debug(String.format("Send kafka 08 message of size %d to topic %s", bytes.length,
topic));
+          KeyedMessage<String, byte[]> producerData = new KeyedMessage((String)topic,
null, bytes);
           Producer nextProducer = producerCircularIterator.next();
           nextProducer.send(producerData);
         }



Mime
View raw message