You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2021/03/19 00:45:00 UTC

[jira] [Created] (KAFKA-12506) Expand AdjustStreamThreadCountTest

A. Sophie Blee-Goldman created KAFKA-12506:
----------------------------------------------

             Summary: Expand AdjustStreamThreadCountTest
                 Key: KAFKA-12506
                 URL: https://issues.apache.org/jira/browse/KAFKA-12506
             Project: Kafka
          Issue Type: Improvement
          Components: streams, unit tests
            Reporter: A. Sophie Blee-Goldman


Right now the AdjustStreamThreadCountTest runs a minimal topology that just consumes a single input topic, and doesn't produce any data to this topic. Some of the complex concurrency bugs that we've found only showed up when we had some actual data to process and a stateful topology: [KAFKA-12503|https://issues.apache.org/jira/browse/KAFKA-12503]

We should try to expand the Streams application in this test to really flex the feature. Imo this would include 

# One or more stateful operators in the topology, with caching enabled
# A repartition to get multiple subtopologies
# Writing to an output topic
# Produce some data to the input topic and verify that some results show up in the output



--
This message was sent by Atlassian Jira
(v8.3.4#803005)