kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-6381) Improve KafkaStreamsTest for localThreadMetadata
Date Mon, 18 Dec 2017 22:14:01 GMT
Matthias J. Sax created KAFKA-6381:

             Summary: Improve KafkaStreamsTest for localThreadMetadata
                 Key: KAFKA-6381
                 URL: https://issues.apache.org/jira/browse/KAFKA-6381
             Project: Kafka
          Issue Type: Improvement
          Components: streams, unit tests
            Reporter: Matthias J. Sax
            Priority: Minor

Currently, we have a rather basic test for {{KafkaStreams#localThreadMetadata}} (ie, {{KafkaStreamsTests#shouldReturnThreadMetadata()}}.

In a PR discussion [~guozhang] mentioned:
I'm wondering if it is better to fill into the topology with some processor and then check
the following active and standby tasks as non-empty would cover more scenarios? In addition,
we can use waitForCondition to wait for the state to become RUNNING and the tasks list become

We should extend the current test method and/or add new test methods to cover this and other

This message was sent by Atlassian JIRA

View raw message