Avoid sending a fail too early to the newly started consumer
otherwise we get a silent background error.
@@ -1020,6 +1020,10 @@ async fn transactional_store_offset_handling() -> Result<()> {
harness.wait_for_connected().await?;
debug!("connected");
+ // give the background librdkafka time to start fetching the partitions before we fail
+ // otherwise it will fail silently in the background
+ // consider this a cry for help!
+ task::sleep(Duration::from_millis(200)).await;
// fail message 2
harness
.send_contraflow(CbAction::Fail, event2.id.clone())
