diff --git a/connector.yaml b/connector.yaml index d458080..9cb2a5a 100644 --- a/connector.yaml +++ b/connector.yaml @@ -91,7 +91,7 @@ specification: deleted, the record will be ignored. If there is no key, the record will be simply appended. - version: v0.12.0 + version: v0.12.1 author: Meroxa, Inc. source: parameters: diff --git a/source/snapshot/iterator.go b/source/snapshot/iterator.go index 480c097..8034fef 100644 --- a/source/snapshot/iterator.go +++ b/source/snapshot/iterator.go @@ -87,7 +87,7 @@ func (i *Iterator) NextN(ctx context.Context, n int) ([]opencdc.Record, error) { return nil, fmt.Errorf("n must be greater than 0, got %d", n) } - records := make([]opencdc.Record, 0, n) + var records []opencdc.Record // Get first record (blocking) select {