Repository: kafka Updated Branches: refs/heads/trunk 61e0eaefd -> ab7325928
KAFKA-3660: Log exception message in ControllerBrokerRequestBatch Author: Flavio Junqueira <[email protected]> Reviewers: Grant Henke <[email protected]>, Ismael Juma <[email protected]>, Ewen Cheslack-Postava <[email protected]> Closes #1325 from fpj/KAFKA-3660 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ab732592 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ab732592 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ab732592 Branch: refs/heads/trunk Commit: ab7325928164b0cc7c26c695ecdf431ce1d89b8d Parents: 61e0eae Author: Flavio Junqueira <[email protected]> Authored: Wed Jun 1 21:03:40 2016 -0700 Committer: Ewen Cheslack-Postava <[email protected]> Committed: Wed Jun 1 21:03:40 2016 -0700 ---------------------------------------------------------------------- .../main/scala/kafka/controller/ControllerChannelManager.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/ab732592/core/src/main/scala/kafka/controller/ControllerChannelManager.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/controller/ControllerChannelManager.scala b/core/src/main/scala/kafka/controller/ControllerChannelManager.scala index 65b7096..b4059a4 100755 --- a/core/src/main/scala/kafka/controller/ControllerChannelManager.scala +++ b/core/src/main/scala/kafka/controller/ControllerChannelManager.scala @@ -426,15 +426,15 @@ class ControllerBrokerRequestBatch(controller: KafkaController) extends Logging case e : Throwable => { if (leaderAndIsrRequestMap.size > 0) { error("Haven't been able to send leader and isr requests, current state of " + - s"the map is $leaderAndIsrRequestMap") + s"the map is $leaderAndIsrRequestMap. Exception message: $e") } if (updateMetadataRequestMap.size > 0) { error("Haven't been able to send metadata update requests, current state of " + - s"the map is $updateMetadataRequestMap") + s"the map is $updateMetadataRequestMap. Exception message: $e") } if (stopReplicaRequestMap.size > 0) { error("Haven't been able to send stop replica requests, current state of " + - s"the map is $stopReplicaRequestMap") + s"the map is $stopReplicaRequestMap. Exception message: $e") } throw new IllegalStateException(e) }
