chore: example limit duration specified stay

Trendyol · Jul 17, 2024 · 5b93807 · 5b93807
1 parent d853d3b
commit 5b93807
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/examples/with-kafka-batch-consumer-with-prebatch/main.go b/examples/with-kafka-batch-consumer-with-prebatch/main.go
@@ -17,8 +17,9 @@ func main() {
 			GroupID: "standart-cg",
 		},
 		BatchConfiguration: &kafka.BatchConfiguration{
-			BatchConsumeFn: batchConsumeFn,
-			PreBatchFn:     preBatch,
+			MessageGroupLimit: 1000,
+			BatchConsumeFn:    batchConsumeFn,
+			PreBatchFn:        preBatch,
 		},
 		RetryEnabled: true,
 		RetryConfiguration: kafka.RetryConfiguration{