[root@node3 ~]# /data/bigdata/confluent/bin/kafka-console-consumer --bootstrap-server node3:9092 --topic tidb_catalog_paimon_distributed_locks --from-beginning
{"id":0,"database":"","table":"","pkNames":null,"isDdl":false,"type":"TIDB_WATERMARK","es":1741081298619,"ts":1741081300750,"sql":"","sqlType":null,"mysqlType":null,"data":null,"old":null,"_tidb":{"watermarkTs":456414015945179148}}
{"id":0,"database":"","table":"","pkNames":null,"isDdl":false,"type":"TIDB_WATERMARK","es":1741081299619,"ts":1741081301750,"sql":"","sqlType":null,"mysqlType":null,"data":null,"old":null,"_tidb":{"watermarkTs":456414016207323143}}
{"id":0,"database":"","table":"","pkNames":null,"isDdl":false,"type":"TIDB_WATERMARK","es":1741081300618,"ts":1741081302750,"sql":"","sqlType":null,"mysqlType":null,"data":null,"old":null,"_tidb":{"watermarkTs":456414016469204997}}
{"id":0,"database":"","table":"","pkNames":null,"isDdl":false,"type":"TIDB_WATERMARK","es":1741081301619,"ts":1741081303752,"sql":"","sqlType":null,"mysqlType":null,"data":null,"old":null,"_tidb":{"watermarkTs":456414016731611146}}
....
感觉同步数据有问题呢