[Debezium] Updating Source label (#1081)

artie-labs · Dec 13, 2024 · 554294e · 554294e
1 parent 6cd5cd1
commit 554294e
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/lib/cdc/util/relational_event.go b/lib/cdc/util/relational_event.go
@@ -28,8 +28,11 @@ type Source struct {
 	Connector string `json:"connector"`
 	TsMs      int64  `json:"ts_ms"`
 	Database  string `json:"db"`
-	Schema    string `json:"schema"`
+	Schema    string `json:"schema,omitempty"`
 	Table     string `json:"table"`
+	// MySQL specific
+	File string `json:"file,omitempty"`
+	Pos  int64  `json:"pos,omitempty"`
 }
 
 func (s *SchemaEventPayload) GetColumns() (*columns.Columns, error) {