fix nil map assignment bug

conduitio-labs · Jan 23, 2025 · 24d8d9f · 24d8d9f
1 parent e8d9532
commit 24d8d9f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/iterator/cdc.go b/iterator/cdc.go
@@ -74,6 +74,11 @@ func NewCDCIterator(ctx context.Context, tableName string, pKey string, sKey str
 		recordsPollingPeriod:   recordsPollingPeriod,
 	}
 
+	// initialize SequenceNumberMap if it is nil
+	if c.lastPosition.SequenceNumberMap == nil {
+		c.lastPosition.SequenceNumberMap = make(map[string]string)
+	}
+
 	// start listening to changes
 	c.tomb, ctx = tomb.WithContext(ctx)
 	c.tomb.Go(func() error {

diff --git a/iterator/combined_iterator.go b/iterator/combined_iterator.go
@@ -79,7 +79,7 @@ func NewCombinedIterator(
 			IteratorType:      position.TypeCDC,
 			Time:              now,
 			AfterSnapshot:     true,
-			SequenceNumberMap: map[string]string{},
+			SequenceNumberMap: make(map[string]string),
 		})
 		if err != nil {
 			return nil, fmt.Errorf("could not create the CDC iterator: %w", err)