[jira] [Updated] (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:all-tabpanel ] Eno Thereska updated KAFKA-3637: Fix Version/s: 0.10.2.0 > 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)
[jira] [Updated] (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:all-tabpanel ] Eno Thereska updated KAFKA-3637: Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-2590) > 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 > > 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)
[jira] [Updated] (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:all-tabpanel ] Eno Thereska updated KAFKA-3637: Description: 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 was: 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). As part of this change, we must remove the Thread.sleep() call in the Kafka Streams integration tests and substitute it with TestUtils.waitUntilTrue(). > Add method that checks if streams are initialised > - > > Key: KAFKA-3637 > URL: https://issues.apache.org/jira/browse/KAFKA-3637 > Project: Kafka > Issue Type: Sub-task > Components: streams >Affects Versions: 0.10.1.0 >Reporter: Eno Thereska >Assignee: Eno Thereska > Labels: newbie > > 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)
[jira] [Updated] (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:all-tabpanel ] Jason Gustafson updated KAFKA-3637: --- Fix Version/s: (was: 0.10.1.0) > Add method that checks if streams are initialised > - > > Key: KAFKA-3637 > URL: https://issues.apache.org/jira/browse/KAFKA-3637 > Project: Kafka > Issue Type: Sub-task > Components: streams >Affects Versions: 0.10.1.0 >Reporter: Eno Thereska >Assignee: Liquan Pei > Labels: newbie > > 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). > As part of this change, we must remove the Thread.sleep() call in the Kafka > Streams integration tests and substitute it with TestUtils.waitUntilTrue(). -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (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:all-tabpanel ] Eno Thereska updated KAFKA-3637: Description: 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). As part of this change, we must remove the Thread.sleep() call in the Kafka Streams integration tests and substitute it with TestUtils.waitUntilTrue(). was: 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). > Add method that checks if streams are initialised > - > > Key: KAFKA-3637 > URL: https://issues.apache.org/jira/browse/KAFKA-3637 > Project: Kafka > Issue Type: Sub-task > Components: streams >Affects Versions: 0.10.1.0 >Reporter: Eno Thereska >Assignee: Liquan Pei > Labels: newbie > Fix For: 0.10.1.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). > As part of this change, we must remove the Thread.sleep() call in the Kafka > Streams integration tests and substitute it with TestUtils.waitUntilTrue(). -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (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:all-tabpanel ] Eno Thereska updated KAFKA-3637: Assignee: (was: Guozhang Wang) > Add method that checks if streams are initialised > - > > Key: KAFKA-3637 > URL: https://issues.apache.org/jira/browse/KAFKA-3637 > Project: Kafka > Issue Type: Sub-task > Components: streams >Affects Versions: 0.10.1.0 >Reporter: Eno Thereska > Labels: newbie > Fix For: 0.10.1.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). -- This message was sent by Atlassian JIRA (v6.3.4#6332)
