kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Eno Thereska (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-3637) Add method that checks if streams are initialised
Date Fri, 27 May 2016 15:21:12 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-3637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15304171#comment-15304171

Eno Thereska commented on KAFKA-3637:

Hi [~tszym]. I just added a method that might help with that as part of https://github.com/apache/kafka/pull/1422.

> 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:
>            Reporter: Eno Thereska
>            Assignee: Liquan Pei
>              Labels: newbie
>             Fix For:
> 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

View raw message