You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by GitBox <gi...@apache.org> on 2019/01/15 18:19:06 UTC

[kafka] Diff for: [GitHub] guozhangwang merged pull request #6144: MINOR: Add log entry for KafkaException

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
index a8db7e8a137..851187319e6 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
@@ -754,7 +754,8 @@ public void run() {
             runLoop();
             cleanRun = true;
         } catch (final KafkaException e) {
-            // just re-throw the exception as it should be logged already
+            log.error("Encountered the following unexpected Kafka exception during processing, " +
+                "this usually indicate Streams internal errors:", e);
             throw e;
         } catch (final Exception e) {
             // we have caught all Kafka related exceptions, and other runtime exceptions


With regards,
Apache Git Services