From ca24881983130e86dea80703389f4e13fde117f0 Mon Sep 17 00:00:00 2001 From: Matt Toohey Date: Wed, 18 Dec 2024 11:18:03 +1100 Subject: [PATCH] sleep away the issue --- backend/runner/pubsub/integration_test.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/backend/runner/pubsub/integration_test.go b/backend/runner/pubsub/integration_test.go index 87988db84..c628799df 100644 --- a/backend/runner/pubsub/integration_test.go +++ b/backend/runner/pubsub/integration_test.go @@ -27,6 +27,11 @@ func TestPubSub(t *testing.T) { in.CopyModule("subscriber"), in.Deploy("publisher"), + // After a deployment is "ready" it can take a second before a consumer group claims partitions. + // "publisher.local" has "from=latest" so we need that group to be ready before we start publishing + // otherwise it will start from the latest offset after claiming partitions. + in.Sleep(time.Second*1), + // publish half the events before subscriber is deployed publishToTestAndLocalTopics(calls/2),