Skip to content

Commit 15caf2e

Browse files
authored
fix snapshot allocation (#285)
1 parent 8aa702c commit 15caf2e

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

connector.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ specification:
9191
deleted, the record will be ignored.
9292
9393
If there is no key, the record will be simply appended.
94-
version: v0.12.0
94+
version: v0.12.1
9595
author: Meroxa, Inc.
9696
source:
9797
parameters:

source/snapshot/iterator.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ func (i *Iterator) NextN(ctx context.Context, n int) ([]opencdc.Record, error) {
8787
return nil, fmt.Errorf("n must be greater than 0, got %d", n)
8888
}
8989

90-
records := make([]opencdc.Record, 0, n)
90+
var records []opencdc.Record
9191

9292
// Get first record (blocking)
9393
select {

0 commit comments

Comments
 (0)