You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2017/10/27 13:10:59 UTC
kafka git commit: MINOR: Fix indentation in
KafkaApis.handleOffsetFetchRequest
Repository: kafka
Updated Branches:
refs/heads/trunk 501a5e262 -> 6197481b8
MINOR: Fix indentation in KafkaApis.handleOffsetFetchRequest
Author: Vahid Hashemian <va...@us.ibm.com>
Reviewers: Ismael Juma <is...@juma.me.uk>
Closes #4139 from vahidhashemian/minor/indentation_fix_1710
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6197481b
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/6197481b
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/6197481b
Branch: refs/heads/trunk
Commit: 6197481b8be0dcf259e4a6f08fa78f120bed5b60
Parents: 501a5e2
Author: Vahid Hashemian <va...@us.ibm.com>
Authored: Fri Oct 27 14:10:56 2017 +0100
Committer: Ismael Juma <is...@juma.me.uk>
Committed: Fri Oct 27 14:10:56 2017 +0100
----------------------------------------------------------------------
core/src/main/scala/kafka/server/KafkaApis.scala | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/6197481b/core/src/main/scala/kafka/server/KafkaApis.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/KafkaApis.scala b/core/src/main/scala/kafka/server/KafkaApis.scala
index 0066702..9db1a26 100644
--- a/core/src/main/scala/kafka/server/KafkaApis.scala
+++ b/core/src/main/scala/kafka/server/KafkaApis.scala
@@ -1054,10 +1054,12 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
}
- trace(s"Sending offset fetch response $offsetFetchResponse for correlation id ${header.correlationId} to client ${header.clientId}.")
- offsetFetchResponse
- }
- sendResponseMaybeThrottle(request, createResponse)
+
+ trace(s"Sending offset fetch response $offsetFetchResponse for correlation id ${header.correlationId} to client ${header.clientId}.")
+ offsetFetchResponse
+ }
+
+ sendResponseMaybeThrottle(request, createResponse)
}
def handleFindCoordinatorRequest(request: RequestChannel.Request) {