Always flush kafka producers in tests
Closed
requested to merge generated-differential-D6016-source into generated-differential-D6016-target
Sometimes, in a very loaded situation, the producer can return and let the consumer start before the topic is actually created.
Adding a producer.flush()
avoids that race condition.
Migrated from D6016 (view on Phabricator)
Merge request reports
Activity
Filter activity
Build is green
Patch application report for D6016 (id=21729)
Rebasing onto d58705a0...
Current branch diff-target is up to date.
Changes applied before test
commit 0a9023b81108244b1ac41e124272a0473f2ff5c3 Author: Nicolas Dandrimont <nicolas@dandrimont.eu> Date: Wed Jul 21 15:12:49 2021 +0200 Always flush kafka producers in tests Sometimes, in a very loaded situation, the producer can return and let the consumer start before the topic is actually created. Adding a `producer.flush()` avoids that race condition.
See https://jenkins.softwareheritage.org/job/DSEA/job/tests-on-diff/223/ for more details.
Build is green
Patch application report for D6016 (id=21755)
Rebasing onto 4e453304...
Current branch diff-target is up to date.
Changes applied before test
commit 122d7caf6577f4090f66e909688178b1e6ce41b1 Author: Nicolas Dandrimont <nicolas@dandrimont.eu> Date: Wed Jul 21 15:12:49 2021 +0200 Always flush kafka producers in tests Sometimes, in a very loaded situation, the producer can return and let the consumer start before the topic is actually created. Adding a `producer.flush()` avoids that race condition.
See https://jenkins.softwareheritage.org/job/DSEA/job/tests-on-diff/231/ for more details.
Please register or sign in to reply