fix race

Signed-off-by: Doug Davis <[email protected]>

test/integration/kafka_sarama_binding/kafka_test.go

@@ -104,7 +104,7 @@ func testSenderReceiver(t testing.TB) (func(), bindings.Sender, bindings.Receive
 
 	// Not perfect but we need to give OpenInbound() as chance to start
 	// as it's a race condition. I couldn't find something on 'p' to wait for
-	time.Sleep(5 * time.Second)
+	time.Sleep(15 * time.Second)
 
 	return func() {
 		require.NoError(t, p.Close(context.TODO()))

v2/client/test/test.go

@@ -10,6 +10,7 @@ import (
 	"context"
 	"sync"
 	"testing"
+	"time"
 
 	"github.com/cloudevents/sdk-go/v2/protocol"
 
@@ -29,6 +30,9 @@ func SendReceive(t *testing.T, protocolFactory func() interface{}, in event.Even
 	wg := sync.WaitGroup{}
 	wg.Add(2)
 
+	// Give time for Kafka client protocol to get setup
+	time.Sleep(5 * time.Second)
+
 	go func() {
 		ctx, cancel := context.WithCancel(context.TODO())
 		inCh := make(chan event.Event)
@@ -49,6 +53,9 @@ func SendReceive(t *testing.T, protocolFactory func() interface{}, in event.Even
 		outAssert(e)
 	}()
 
+	// Give time for the receiever to start
+	time.Sleep(5 * time.Second)
+
 	go func() {
 		defer wg.Done()
 		err := c.Send(context.Background(), in)