From e74a90c1f48842dbb04276b6bdc4e58fbf760b40 Mon Sep 17 00:00:00 2001 From: Jayant Goel Date: Wed, 16 Apr 2025 14:41:13 +0530 Subject: [PATCH] Reduce Time taken to execute SLTs --- pkg/grillkafka/assertions.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/grillkafka/assertions.go b/pkg/grillkafka/assertions.go index ac79629..3db7c8b 100644 --- a/pkg/grillkafka/assertions.go +++ b/pkg/grillkafka/assertions.go @@ -12,7 +12,7 @@ import ( func (gk *Kafka) AssertCount(topicName string, expectedCount int) grill.Assertion { return grill.AssertionFunc(func() error { group := fmt.Sprintf("%s_%d_%s", "oh_my_test_helper", rand.Intn(1000), time.Now()) - consumer, err := gk.NewConsumer(group, topicName, time.Second*5) + consumer, err := gk.NewConsumer(group, topicName, time.Second) if err != nil { return err } @@ -33,7 +33,7 @@ func (gk *Kafka) AssertCount(topicName string, expectedCount int) grill.Assertio func (gk *Kafka) AssertMessageCount(topic string, message Message, expectedCount int) grill.Assertion { return grill.AssertionFunc(func() error { group := fmt.Sprintf("%s_%d_%s", "oh_my_test_helper", rand.Intn(1000), time.Now()) - consumer, err := gk.NewConsumer(group, topic, time.Second*5) + consumer, err := gk.NewConsumer(group, topic, time.Second) if err != nil { return err }