root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

trivial fix for stylecheck error on Jenkins

This commit is contained in:
Jun Rao 2015-06-16 16:41:20 -07:00
parent 9650e12df2
commit ba86f0a25d
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clients/src/main/java/org/apache/kafka/common/requests/ConsumerMetadataRequest.java
View File

@ -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:

2
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
View File

@ -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:

2
clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java
View File

@ -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:

2
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java
View File

@ -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: