Merge pull request #20 from blukat29/kafka-test-timeout

kafka: Relax kafka_test timeout
kaiachain · Jun 21, 2024 · c03bca6 · c03bca6
2 parents 1c2cc0e + 1a989cf
commit c03bca6
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/datasync/chaindatafetcher/kafka/kafka_test.go b/datasync/chaindatafetcher/kafka/kafka_test.go
@@ -232,7 +232,7 @@ func (s *KafkaSuite) subscribeData(topic, groupId string, numTests int, handler
 	}()
 
 	// wait for all data to be consumed
-	timeout := time.NewTimer(5 * time.Second)
+	timeout := time.NewTimer(10 * time.Second)
 	for i := 0; i < numTests; i++ {
 		select {
 		case <-numCheckCh:
@@ -473,7 +473,7 @@ func (s *KafkaSuite) TestKafka_PubSubWithSegements_BufferOverflow() {
 	}()
 
 	// checkout the returned error is buffer overflow error
-	timeout := time.NewTimer(5 * time.Second)
+	timeout := time.NewTimer(10 * time.Second)
 	select {
 	case <-timeout.C:
 		s.Fail("timeout")
@@ -508,7 +508,7 @@ func (s *KafkaSuite) TestKafka_PubSubWithSegments_ErrCallBack() {
 	}()
 
 	// checkout the returned error is callback error
-	timeout := time.NewTimer(5 * time.Second)
+	timeout := time.NewTimer(10 * time.Second)
 	select {
 	case <-timeout.C:
 		s.Fail("timeout")
@@ -550,7 +550,7 @@ func (s *KafkaSuite) TestKafka_PubSubWithSegments_MessageTimeout() {
 	}()
 
 	// checkout the returned error is callback error
-	timeout := time.NewTimer(5 * time.Second)
+	timeout := time.NewTimer(10 * time.Second)
 	select {
 	case <-timeout.C:
 		s.Fail("timeout")