You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2015/06/17 01:41:31 UTC
kafka git commit: trivial fix for stylecheck error on Jenkins
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 <ju...@gmail.com>
Authored: Tue Jun 16 16:41:20 2015 -0700
Committer: Jun Rao <ju...@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: