Fix unknown type for mediumint (#962)

pingcap · May 12, 2020 · 12b6ed5 · 12b6ed5
1 parent dcc9047
commit 12b6ed5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/drainer/translator/kafka.go b/drainer/translator/kafka.go
@@ -229,7 +229,8 @@ func DatumToColumn(colInfo *model.ColumnInfo, datum types.Datum) (col *obinlog.C
 		col.StringValue = proto.String(str)
 
 	// numeric type
-	case "int", "bigint", "smallint", "tinyint":
+	// https://dev.mysql.com/doc/refman/8.0/en/integer-types.html
+	case "int", "bigint", "smallint", "tinyint", "mediumint":
 		str := fmt.Sprintf("%v", datum.GetValue())
 		if mysql.HasUnsignedFlag(colInfo.Flag) {
 			val, err := strconv.ParseUint(str, 10, 64)