From 4c48a48551ea3aa1ac395e5afc27032b654c15ed Mon Sep 17 00:00:00 2001 From: nhsmw Date: Fri, 13 Dec 2024 17:50:11 +0800 Subject: [PATCH 1/2] Update encoder.go --- pkg/sink/codec/debezium/encoder.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/sink/codec/debezium/encoder.go b/pkg/sink/codec/debezium/encoder.go index 085a292ffd0..532ad59a1c2 100644 --- 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) From 95616802a5d2a8598921433d8a1f18e215c5690c Mon Sep 17 00:00:00 2001 From: wk989898 Date: Fri, 13 Dec 2024 18:14:00 +0800 Subject: [PATCH 2/2] fmt --- pkg/sink/codec/debezium/encoder.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/sink/codec/debezium/encoder.go b/pkg/sink/codec/debezium/encoder.go index 532ad59a1c2..2ffdb1b6ba4 100644 --- a/pkg/sink/codec/debezium/encoder.go +++ b/pkg/sink/codec/debezium/encoder.go @@ -39,7 +39,7 @@ type BatchEncoder struct { 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)