Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
0.10.1.0
-
None
Description
The integration tests for streams rely on timeouts to check when data has been processed. The timeouts are often large (e.g, 10 seconds) and still occasionally they trigger prematurely. They need to be replaced by waitUntilTrue and some logic that checks when processing in streams is complete.
Attachments
Issue Links
- is related to
-
KAFKA-3637 Add method that checks if streams are initialised
- Resolved
- links to