Staging instance, all changes can be removed at any time

Skip to content

Always flush kafka producers in tests

Nicolas Dandrimont 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