sink(ticdc): add parameter to enable watermark events in the Debezium…

… protocol (#11877) close #11876
pingcap · Jan 4, 2025 · 1dd87cf · 1dd87cf
1 parent beee317
commit 1dd87cf
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/sink/codec/debezium/encoder.go b/pkg/sink/codec/debezium/encoder.go
@@ -37,6 +37,9 @@ type BatchEncoder struct {
 
 // EncodeCheckpointEvent implements the RowEventEncoder interface
 func (d *BatchEncoder) EncodeCheckpointEvent(ts uint64) (*common.Message, error) {
+	if !d.config.EnableTiDBExtension {
+		return nil, nil
+	}
 	keyMap := bytes.Buffer{}
 	valueBuf := bytes.Buffer{}
 	err := d.codec.EncodeCheckpointEvent(ts, &keyMap, &valueBuf)