chore: fix transactionalRetry integration test flakyness

Trendyol · Dec 16, 2023 · 326e147 · 326e147
1 parent b18e8bd
commit 326e147
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/test/integration/integration_test.go b/test/integration/integration_test.go
@@ -186,7 +186,7 @@ func Test_Should_Batch_Retry_Only_Failed_Messages_When_Transactional_Retry_Is_Di
 			MaxRetry:      3,
 			LogLevel:      "error",
 		},
-		MessageGroupDuration: time.Second,
+		MessageGroupDuration: 5 * time.Second,
 		BatchConfiguration: &kafka.BatchConfiguration{
 			MessageGroupLimit: 100,
 			BatchConsumeFn: func(messages []*kafka.Message) error {