Repository: kafka Updated Branches: refs/heads/0.10.0 5aa20fb57 -> 946ae60a4
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 (cherry picked from commit ab7325928164b0cc7c26c695ecdf431ce1d89b8d) Signed-off-by: Ewen Cheslack-Postava <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/946ae60a Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/946ae60a Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/946ae60a Branch: refs/heads/0.10.0 Commit: 946ae60a4c8b694bfad65f20348d8081f103830b Parents: 5aa20fb 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:04:01 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/946ae60a/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) }
