You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2018/07/12 06:01:01 UTC
[kafka] branch trunk updated: MINOR: Print exception stack traces
in ConsumerGroupCommand. (#5286)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 000a2d4 MINOR: Print exception stack traces in ConsumerGroupCommand. (#5286)
000a2d4 is described below
commit 000a2d42cb813768866a52a652176c253babb043
Author: Aviem Zur <av...@gmail.com>
AuthorDate: Thu Jul 12 09:00:55 2018 +0300
MINOR: Print exception stack traces in ConsumerGroupCommand. (#5286)
Reviewers: Guozhang Wang <wa...@gmail.com>
---
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala b/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
index d5a57ee..435c2fd 100755
--- a/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
+++ b/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
@@ -80,7 +80,7 @@ object ConsumerGroupCommand extends Logging {
def printError(msg: String, e: Option[Throwable] = None): Unit = {
println(s"Error: $msg")
- e.foreach(debug("Exception in consumer group command", _))
+ e.foreach(_.printStackTrace())
}
def convertTimestamp(timeString: String): java.lang.Long = {