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 <junrao@gmail.com>
Authored: Tue Jun 16 16:41:20 2015 -0700
Committer: Jun Rao <junrao@gmail.com>
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: