You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/11/15 11:43:58 UTC
[jira] [Commented] (KAFKA-3637) Add method that checks if streams
are initialised
[ https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666928#comment-15666928 ]
ASF GitHub Bot commented on KAFKA-3637:
---------------------------------------
GitHub user enothereska opened a pull request:
https://github.com/apache/kafka/pull/2135
KAFKA-3637: Added initial states
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/enothereska/kafka KAFKA-3637-streams-state
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2135.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2135
----
commit 80548e1179adfae5d41a90c9bd43cd60ae37d5bf
Author: Eno Thereska <en...@gmail.com>
Date: 2016-11-15T11:42:34Z
Added initial states
----
> Add method that checks if streams are initialised
> -------------------------------------------------
>
> Key: KAFKA-3637
> URL: https://issues.apache.org/jira/browse/KAFKA-3637
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 0.10.1.0
> Reporter: Eno Thereska
> Assignee: Eno Thereska
> Labels: newbie
> Fix For: 0.10.2.0
>
>
> Currently when streams are initialised and started with streams.start(), there is no way for the caller to know if the initialisation procedure (including starting tasks) is complete or not. Hence, the caller is forced to guess for how long to wait. It would be good to have a way to return the state of the streams to the caller.
> One option would be to follow a similar approach in Kafka Server (BrokerStates.scala).
> Would be good for example, to keep track of whether Kafka Streams is starting/running/rebalancing
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)