Skip to content

Commit 5102361

Browse files
committed
embed stacktrace in log message
1 parent aa7eea1 commit 5102361

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

common/scala/src/main/scala/org/apache/openwhisk/core/connector/MessageConsumer.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ import scala.util.Failure
2626
import org.apache.kafka.clients.consumer.CommitFailedException
2727
import akka.actor.FSM
2828
import akka.pattern.pipe
29+
import org.apache.commons.lang3.exception.ExceptionUtils
2930
import org.apache.openwhisk.common.Logging
3031
import org.apache.openwhisk.common.TransactionId
3132

@@ -216,7 +217,8 @@ class MessageFeed(description: String,
216217
handler(bytes).andThen {
217218
{
218219
case Failure(e) =>
219-
logging.error(this, s"Failed to process message for topic $topic : $e (stack trace included)")
220+
val stacktrace = ExceptionUtils.getStackTrace(e)
221+
logging.error(this, s"Failed to process message for topic $topic : $e : stacktrace: $stacktrace")
220222
e.printStackTrace()
221223
}
222224
}

0 commit comments

Comments
 (0)