Sleep less to avoid timeouts

Doug Davis · Doug Davis · commit 13825ba9352b · 2023-10-24T15:00:34.000Z
Signed-off-by: Doug Davis &lt;dug@microsoft.com&gt;
diff --git a/test/integration/kafka_sarama_binding/kafka_test.go b/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(15 * time.Second)
+	time.Sleep(6 * time.Second)
 
 	return func() {
 		require.NoError(t, p.Close(context.TODO()))
diff --git a/v2/client/test/test.go b/v2/client/test/test.go
@@ -31,7 +31,7 @@ func SendReceive(t *testing.T, protocolFactory func() interface{}, in event.Even
 	wg.Add(2)
 
 	// Give time for Kafka client protocol to get setup
-	time.Sleep(5 * time.Second)
+	time.Sleep(2 * time.Second)
 
 	go func() {
 		ctx, cancel := context.WithCancel(context.TODO())
@@ -54,7 +54,7 @@ func SendReceive(t *testing.T, protocolFactory func() interface{}, in event.Even
 	}()
 
 	// Give time for the receiever to start
-	time.Sleep(5 * time.Second)
+	time.Sleep(2 * time.Second)
 
 	go func() {
 		defer wg.Done()
