kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch 1.1 updated: KAFKA-7198: Enhance KafkaStreams start method javadoc. (#5763)
Date Tue, 09 Oct 2018 17:00:42 GMT
This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git

The following commit(s) were added to refs/heads/1.1 by this push:
     new 4b0cefc  KAFKA-7198: Enhance KafkaStreams start method javadoc. (#5763)
4b0cefc is described below

commit 4b0cefcb8942b13f27547854ec90ab2ac402bebe
Author: Kamal Chandraprakash <kamal.chandraprakash@gmail.com>
AuthorDate: Tue Oct 9 22:28:12 2018 +0530

    KAFKA-7198: Enhance KafkaStreams start method javadoc. (#5763)
    Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@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 08120ef..ced0291 100644
--- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
+++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
@@ -742,6 +742,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}

View raw message