parse.

artie-labs · Oct 30, 2024 · aea5d34 · aea5d34
1 parent ade10cf
commit aea5d34
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/cdc/mongo/debezium.go b/lib/cdc/mongo/debezium.go
@@ -178,7 +178,11 @@ func (s *SchemaEventPayload) GetData(pkMap map[string]any, tc kafkalib.TopicConf
 
 		if _, isOk := retMap["ts"]; !isOk {
 			slog.Info("ts not found in data, adding it", slog.String("table", s.GetTableName()))
-			objectID := retMap["_id"].(primitive.ObjectID)
+			objectID, err := primitive.ObjectIDFromHex(retMap["_id"].(string))
+			if err != nil {
+				panic(fmt.Sprintf("failed to parse ObjectID: %v", err))
+			}
+
 			retMap["ts"] = objectID.Timestamp()
 		}
 	case "r", "u", "c":