diff --git a/pkg/cmd/util/helper_test.go b/pkg/cmd/util/helper_test.go
index 07149f7cf03..3fdb15544f2 100644
--- a/pkg/cmd/util/helper_test.go
+++ b/pkg/cmd/util/helper_test.go
@@ -191,7 +191,7 @@ func TestAndWriteExampleReplicaTOML(t *testing.T) {
 	err = cfg.ValidateAndAdjust(sinkURL)
 	require.NoError(t, err)
 	require.Equal(t, &config.SinkConfig{
-		EncoderConcurrency: util.AddressOf(16),
+		EncoderConcurrency: util.AddressOf(config.DefaultEncoderGroupConcurrency),
 		DispatchRules: []*config.DispatchRule{
 			{PartitionRule: "ts", TopicRule: "hello_{schema}", Matcher: []string{"test1.*", "test2.*"}},
 			{PartitionRule: "rowid", TopicRule: "{schema}_world", Matcher: []string{"test3.*", "test4.*"}},
@@ -230,7 +230,7 @@ func TestAndWriteStorageSinkTOML(t *testing.T) {
 	require.NoError(t, err)
 	require.Equal(t, &config.SinkConfig{
 		Protocol:                 util.AddressOf(config.ProtocolCanalJSON.String()),
-		EncoderConcurrency:       util.AddressOf(16),
+		EncoderConcurrency:       util.AddressOf(config.DefaultEncoderGroupConcurrency),
 		Terminator:               util.AddressOf(config.CRLF),
 		TxnAtomicity:             util.AddressOf(config.AtomicityLevel("")),
 		DateSeparator:            util.AddressOf("day"),