output kafka tableMap 格式输出新增 binlog_timestamp 字段

brokercap · Oct 16, 2024 · 59a99e0 · 59a99e0
1 parent 5a3ef3a
commit 59a99e0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/plugin/driver/table_map_json.go b/plugin/driver/table_map_json.go
@@ -19,6 +19,7 @@ func (c *PluginDataType) ToTableMapObject() (data map[string]interface{}, err er
 	} else {
 		data["bifrost_query"] = c.Query
 	}
+	data["binlog_timestamp"] = fmt.Sprint(c.Timestamp)
 	data["binlog_event_type"] = c.EventType
 	data["bifrost_pri"] = strings.Join(c.Pri, ",")
 	data["bifrost_database"] = c.SchemaName