Return-Path: X-Original-To: apmail-kafka-commits-archive@www.apache.org Delivered-To: apmail-kafka-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 5F58217365 for ; Tue, 13 Jan 2015 17:55:29 +0000 (UTC) Received: (qmail 77344 invoked by uid 500); 13 Jan 2015 17:55:31 -0000 Delivered-To: apmail-kafka-commits-archive@kafka.apache.org Received: (qmail 77316 invoked by uid 500); 13 Jan 2015 17:55:31 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 77307 invoked by uid 99); 13 Jan 2015 17:55:31 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 13 Jan 2015 17:55:31 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id BF4D89AF8C9; Tue, 13 Jan 2015 17:55:30 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: junrao@apache.org To: commits@kafka.apache.org Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: kafka git commit: trivial change to add byte serializer to ProducerPerformance; patched by Jun Rao Date: Tue, 13 Jan 2015 17:55:30 +0000 (UTC) Repository: kafka Updated Branches: refs/heads/trunk e79ebdfe2 -> bfb2da3c8 trivial change to add byte serializer to ProducerPerformance; patched 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/bfb2da3c Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/bfb2da3c Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/bfb2da3c Branch: refs/heads/trunk Commit: bfb2da3c82ab01f5914d5559ee196d5aa977b17c Parents: e79ebdf Author: Jun Rao Authored: Tue Jan 13 09:54:32 2015 -0800 Committer: Jun Rao Committed: Tue Jan 13 09:54:54 2015 -0800 ---------------------------------------------------------------------- .../org/apache/kafka/clients/tools/ProducerPerformance.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/bfb2da3c/clients/src/main/java/org/apache/kafka/clients/tools/ProducerPerformance.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/clients/tools/ProducerPerformance.java b/clients/src/main/java/org/apache/kafka/clients/tools/ProducerPerformance.java index 1b82800..689bae9 100644 --- a/clients/src/main/java/org/apache/kafka/clients/tools/ProducerPerformance.java +++ b/clients/src/main/java/org/apache/kafka/clients/tools/ProducerPerformance.java @@ -15,10 +15,7 @@ package org.apache.kafka.clients.tools; import java.util.Arrays; import java.util.Properties; -import org.apache.kafka.clients.producer.Callback; -import org.apache.kafka.clients.producer.KafkaProducer; -import org.apache.kafka.clients.producer.ProducerRecord; -import org.apache.kafka.clients.producer.RecordMetadata; +import org.apache.kafka.clients.producer.*; public class ProducerPerformance { @@ -46,6 +43,8 @@ public class ProducerPerformance { throw new IllegalArgumentException("Invalid property: " + args[i]); props.put(pieces[0], pieces[1]); } + props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.ByteArraySerializer"); + props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.ByteArraySerializer"); KafkaProducer producer = new KafkaProducer(props); /* setup perf test */