[
https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15701403#comment-15701403
]
ASF GitHub Bot commented on KAFKA-3637:
---------------------------------------
GitHub user enothereska reopened 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 <[email protected]>
Date: 2016-11-15T11:42:34Z
Added initial states
commit c55bf580b0bb35f0350491eae9b15218e9b74e16
Author: Eno Thereska <[email protected]>
Date: 2016-11-18T13:34:43Z
Merge with trunk and address comments
commit aa48efe835d98d13e91fc40bf6ec189eeed94d3d
Author: Eno Thereska <[email protected]>
Date: 2016-11-23T16:52:23Z
Added state listener for thread
commit c548ada9097be4e3084a71a013be22f062caffd0
Author: Eno Thereska <[email protected]>
Date: 2016-11-23T17:09:35Z
Renamed a few variables, removed initialized variable
commit ffa1b2c923ac5c267b710c5cdf7b7ca3bf4660ac
Author: Eno Thereska <[email protected]>
Date: 2016-11-23T18:46:06Z
Added state validation
commit 8a6e722f3f5aad3d3a6c2e9f6c4749609bf27c05
Author: Eno Thereska <[email protected]>
Date: 2016-11-25T10:13:06Z
Dan's comments
commit b320c03e38df1fd946e71fa22c6bfb864ba25caa
Author: Eno Thereska <[email protected]>
Date: 2016-11-25T11:54:47Z
Damian's suggestions
----
> 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)
