Skip to content
Snippets Groups Projects

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.


Migrated from D6016 (view on Phabricator)

Merge request reports

Closed by Phabricator Migration userPhabricator Migration user 3 years ago (Jul 23, 2021 8:32am UTC)

Loading

Activity

Filter activity
  • Approvals
  • Assignees & reviewers
  • Comments (from bots)
  • Comments (from users)
  • Commits & branches
  • Edits
  • Labels
  • Lock status
  • Mentions
  • Merge request status
  • Tracking
Please register or sign in to reply
Loading