Cleanup history

Signed-off-by: Wish <breezewish@outlook.com>
pingcap · Dec 15, 2023 · c56c068 · c56c068
1 parent c6b3fec
commit c56c068
Show file tree

Hide file tree

Showing 6 changed files with 868 additions and 153 deletions.
diff --git a/pkg/sink/codec/builder/encoder_builder.go b/pkg/sink/codec/builder/encoder_builder.go
@@ -49,7 +49,7 @@ func NewRowEventEncoderBuilder(
 	case config.ProtocolCraft:
 		return craft.NewBatchEncoderBuilder(cfg), nil
 	case config.ProtocolDebezium:
-		return debezium.NewBatchEncoderBuilder(cfg), nil
+		return debezium.NewBatchEncoderBuilder(cfg, config.GetGlobalServerConfig().ClusterID), nil
 	case config.ProtocolSimple:
 		return simple.NewBuilder(cfg), nil
 	default: