svn commit: r1410588 - in /incubator/kafka/branches/0.8/core/src/main/scala/kafka: javaapi/producer/ProducerData.scala tools/KafkaMigrationTool.java

[jk...@apache.org]

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);
         }