Set autocommit default to false

Signed-off-by: Gabriele Santomaggio <[email protected]>
rabbitmq · Jun 25, 2024 · 8b29661 · 8b29661
1 parent 8ae5dbf
commit 8b29661
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/stream/super_stream_consumer.go b/pkg/stream/super_stream_consumer.go
@@ -20,7 +20,8 @@ type SuperStreamConsumerOptions struct {
 
 func NewSuperStreamConsumerOptions() *SuperStreamConsumerOptions {
 	return &SuperStreamConsumerOptions{
-		Offset: OffsetSpecification{}.Next(),
+		Offset:     OffsetSpecification{}.Next(),
+		Autocommit: false,
 	}
 }