From 1a989cf939f5acfe3a6ba40b18b1137814867ef6 Mon Sep 17 00:00:00 2001 From: "ollie.j" Date: Fri, 21 Jun 2024 14:47:57 +0900 Subject: [PATCH] kafka: Relax kafka_test timeout --- datasync/chaindatafetcher/kafka/kafka_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/datasync/chaindatafetcher/kafka/kafka_test.go b/datasync/chaindatafetcher/kafka/kafka_test.go index 8d9f3610b..c8ea1ccd1 100644 --- 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")