Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
Description
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 KAFKA-12500
See the umbrella ticket for the list of improvements we need to make this a more effective integration test
Attachments
Issue Links
- links to