From b86c0af230d571fdc0821021bf0371b627f06a17 Mon Sep 17 00:00:00 2001 From: Abdulsametileri Date: Thu, 28 Mar 2024 09:27:31 +0300 Subject: [PATCH] chore: fix integration test --- test/integration/integration_test.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/test/integration/integration_test.go b/test/integration/integration_test.go index e4d47fb..fc3751e 100644 --- a/test/integration/integration_test.go +++ b/test/integration/integration_test.go @@ -242,12 +242,11 @@ func Test_Should_Batch_Retry_Only_Failed_Messages_When_Transactional_Retry_Is_Di RetryConfiguration: kafka.RetryConfiguration{ Brokers: []string{brokerAddress}, Topic: retryTopic, - StartTimeCron: "*/1 * * * *", - WorkDuration: 50 * time.Second, + StartTimeCron: "*/5 * * * *", + WorkDuration: 4 * time.Minute, MaxRetry: 3, - LogLevel: "error", }, - MessageGroupDuration: 10 * time.Second, + MessageGroupDuration: 20 * time.Second, BatchConfiguration: &kafka.BatchConfiguration{ MessageGroupLimit: 5, BatchConsumeFn: func(messages []*kafka.Message) error {