You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2018/10/09 17:01:13 UTC
[kafka] branch 1.0 updated: KAFKA-7198: Enhance KafkaStreams start
method javadoc. (#5763)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new 98cf150 KAFKA-7198: Enhance KafkaStreams start method javadoc. (#5763)
98cf150 is described below
commit 98cf150bd8b4577e55b73bca304d0e86250c49b6
Author: Kamal Chandraprakash <ka...@gmail.com>
AuthorDate: Tue Oct 9 22:28:12 2018 +0530
KAFKA-7198: Enhance KafkaStreams start method javadoc. (#5763)
Reviewers: Bill Bejeck <bi...@confluent.io>, Matthias J. Sax <ma...@confluent.io>
---
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java | 1 +
1 file changed, 1 insertion(+)
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 6f3c112..9d5bdab 100644
--- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
+++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
@@ -733,6 +733,7 @@ public class KafkaStreams {
* 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.
+ * However, if you have global stores in your topology, this method blocks until all global stores are restored.
* 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}