sink(cdc): kafka producer use default configuration. (pingcap#4359)

close pingcap#4383, close pingcap#4499
ti-chi-bot · Feb 24, 2022 · 8899b87 · 8899b87
1 parent d4d6975
commit 8899b87
Show file tree

Hide file tree

Showing 14 changed files with 863 additions and 422 deletions.
diff --git a/cdc/model/schema_storage.go b/cdc/model/schema_storage.go
@@ -17,14 +17,12 @@ import (
 	"fmt"
 
 	"github.com/pingcap/log"
-
-	"go.uber.org/zap"
-
 	"github.com/pingcap/parser/model"
 	"github.com/pingcap/parser/mysql"
 	"github.com/pingcap/parser/types"
 	"github.com/pingcap/tidb/table/tables"
 	"github.com/pingcap/tidb/util/rowcodec"
+	"go.uber.org/zap"
 )
 
 const (
@@ -139,7 +137,7 @@ func WrapTableInfo(schemaID int64, schemaName string, version uint64, info *mode
 
 	ti.findHandleIndex()
 	ti.initColumnsFlag()
-	log.Debug("warpped table info", zap.Reflect("tableInfo", ti))
+	log.Debug("warped table info", zap.Reflect("tableInfo", ti))
 	return ti
 }
 

diff --git a/cdc/owner/async_sink.go b/cdc/owner/async_sink.go
diff --git a/cdc/owner/async_sink_test.go b/cdc/owner/async_sink_test.go