sleep away the issue

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),