From commits-return-2399-apmail-kafka-commits-archive=kafka.apache.org@kafka.apache.org Tue Jun 16 23:41:31 2015 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 90F08181D6 for ; Tue, 16 Jun 2015 23:41:31 +0000 (UTC) Received: (qmail 1225 invoked by uid 500); 16 Jun 2015 23:41:31 -0000 Delivered-To: apmail-kafka-commits-archive@kafka.apache.org Received: (qmail 1199 invoked by uid 500); 16 Jun 2015 23:41: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 1189 invoked by uid 99); 16 Jun 2015 23:41:31 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 16 Jun 2015 23:41:31 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 0A961E3C48; Tue, 16 Jun 2015 23:41:31 +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 fix for stylecheck error on Jenkins Date: Tue, 16 Jun 2015 23:41:31 +0000 (UTC) Repository: kafka Updated Branches: refs/heads/trunk 9650e12df -> ba86f0a25 trivial fix for stylecheck error on Jenkins Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ba86f0a2 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ba86f0a2 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ba86f0a2 Branch: refs/heads/trunk Commit: ba86f0a25dd8675d3c840c33605494a2f637576f Parents: 9650e12 Author: Jun Rao Authored: Tue Jun 16 16:41:20 2015 -0700 Committer: Jun Rao Committed: Tue Jun 16 16:41:20 2015 -0700 ---------------------------------------------------------------------- .../org/apache/kafka/common/requests/ConsumerMetadataRequest.java | 2 +- .../main/java/org/apache/kafka/common/requests/FetchRequest.java | 2 +- .../java/org/apache/kafka/common/requests/HeartbeatRequest.java | 2 +- .../java/org/apache/kafka/common/requests/ListOffsetRequest.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/ba86f0a2/clients/src/main/java/org/apache/kafka/common/requests/ConsumerMetadataRequest.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/common/requests/ConsumerMetadataRequest.java b/clients/src/main/java/org/apache/kafka/common/requests/ConsumerMetadataRequest.java index fef22d7..5b3e04a 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/ConsumerMetadataRequest.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/ConsumerMetadataRequest.java @@ -42,7 +42,7 @@ public class ConsumerMetadataRequest extends AbstractRequest { @Override public AbstractRequestResponse getErrorResponse(int versionId, Throwable e) { - switch(versionId) { + switch (versionId) { case 0: return new ConsumerMetadataResponse(Errors.CONSUMER_COORDINATOR_NOT_AVAILABLE.code(), Node.noNode()); default: http://git-wip-us.apache.org/repos/asf/kafka/blob/ba86f0a2/clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java b/clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java index 4f52c32..df073a0 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java @@ -130,7 +130,7 @@ public class FetchRequest extends AbstractRequest { responseData.put(entry.getKey(), partitionResponse); } - switch(versionId) { + switch (versionId) { case 0: return new FetchResponse(responseData); default: http://git-wip-us.apache.org/repos/asf/kafka/blob/ba86f0a2/clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java b/clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java index d4d4a35..89719f1 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java @@ -50,7 +50,7 @@ public class HeartbeatRequest extends AbstractRequest { @Override public AbstractRequestResponse getErrorResponse(int versionId, Throwable e) { - switch(versionId) { + switch (versionId) { case 0: return new HeartbeatResponse(Errors.forException(e).code()); default: http://git-wip-us.apache.org/repos/asf/kafka/blob/ba86f0a2/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java b/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java index a1bb2b2..6da4a0e 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java @@ -115,7 +115,7 @@ public class ListOffsetRequest extends AbstractRequest { responseData.put(entry.getKey(), partitionResponse); } - switch(versionId) { + switch (versionId) { case 0: return new ListOffsetResponse(responseData); default: