kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: MINOR: add hint for setting an uncaught exception handler to JavaDocs
Date Mon, 23 Oct 2017 09:33:46 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 86cd558b3 -> c216adb4b


MINOR: add hint for setting an uncaught exception handler to JavaDocs

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Bill Bejeck <bill@confluent.io>, Damian Guy <damian.guy@gmail.com>

Closes #4104 from mjsax/minor-uncaught-exception-handler


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c216adb4
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c216adb4
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c216adb4

Branch: refs/heads/trunk
Commit: c216adb4bbf8306977380a1ec371380e30137765
Parents: 86cd558
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Mon Oct 23 10:33:51 2017 +0100
Committer: Damian Guy <damian.guy@gmail.com>
Committed: Mon Oct 23 10:33:51 2017 +0100

----------------------------------------------------------------------
 .../src/main/java/org/apache/kafka/streams/KafkaStreams.java   | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/c216adb4/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
index ae4ef34..6e48f19 100644
--- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
+++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
@@ -723,6 +723,12 @@ public class KafkaStreams {
      * Start the {@code KafkaStreams} instance by starting all its threads.
      * This function is expected to be called only once during the life cycle of the client.
      * <p>
+     * Because threads are started in the background, this method does not block.
+     * As a consequence, any fatal exception that happens during processing is by default
only logged.
+     * If you want to be notified about dying threads, you can
+     * {@link #setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler) register an uncaught
exception handler}
+     * before starting the {@code KafkaStreams} instance.
+     * <p>
      * Note, for brokers with version {@code 0.9.x} or lower, the broker version cannot be
checked.
      * There will be no error and the client will hang and retry to verify the broker version
until it
      * {@link StreamsConfig#REQUEST_TIMEOUT_MS_CONFIG times out}.


Mime
View raw message