From 554294ead53ce10ecfb687713c9434e4759f0bf8 Mon Sep 17 00:00:00 2001
From: Robin Tang <rtang.cs@gmail.com>
Date: Fri, 13 Dec 2024 15:21:50 -0800
Subject: [PATCH] [Debezium] Updating `Source` label (#1081)

---
 lib/cdc/util/relational_event.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/lib/cdc/util/relational_event.go b/lib/cdc/util/relational_event.go
index 01cc01583..69b6e4384 100644
--- 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) {