Clean up.

sources/mysql/adapter/adapter.go

@@ -83,7 +83,17 @@ func (m MySQLAdapter) PartitionKeys() []string {
 
 func valueConverterForType(d schema.DataType, opts *schema.Opts) (converters.ValueConverter, error) {
 	switch d {
-	case schema.Bit, schema.Boolean:
+	case schema.Bit:
+		if opts == nil || opts.Size == nil {
+			return nil, fmt.Errorf("size is required for bit type")
+		}
+
+		if *opts.Size == 1 {
+			return converters.BooleanPassthrough{}, nil
+		}
+
+		return converters.BytesPassthrough{}, nil
+	case schema.Boolean:
 		return converters.BooleanPassthrough{}, nil
 	case schema.TinyInt, schema.SmallInt:
 		return converters.Int16Passthrough{}, nil

sources/mysql/adapter/adapter_test.go

@@ -68,13 +68,27 @@ func TestValueConverterForType(t *testing.T) {
 			expectedErr: "unable get value converter for DataType(-1)",
 		},
 		{
-			name:     "bit",
+			name:     "bit(1)",
 			dataType: schema.Bit,
+			opts: &schema.Opts{
+				Size: typing.ToPtr(1),
+			},
 			expected: debezium.Field{
 				Type:      "boolean",
 				FieldName: colName,
 			},
 		},
+		{
+			name:     "bit(5)",
+			dataType: schema.Bit,
+			opts: &schema.Opts{
+				Size: typing.ToPtr(5),
+			},
+			expected: debezium.Field{
+				Type:      debezium.Bytes,
+				FieldName: colName,
+			},
+		},
 		{
 			name:     "tinyint",
 			dataType: schema.TinyInt,