rm default event handler

dtunikov · dtunikov · commit cbf661cdefb1 · 2026-07-06T15:23:37.000+02:00
diff --git a/flow/connectors/mysql/cdc.go b/flow/connectors/mysql/cdc.go
@@ -818,8 +818,6 @@ func (c *MySqlConnector) PullRecords(
 					e := exceptions.NewMySQLUnsupportedBinlogRowValueOptionsError(string(ev.Table.Schema), string(ev.Table.Table))
 					c.logger.Error(e.Error())
 					return e
-				default:
-					return fmt.Errorf("unhandled mysql rows event type: %s", event.Header.EventType)
 				}
 			}
 			if event.Header.Timestamp > 0 {

Original file line number	Diff line number	Diff line change
`@@ -818,8 +818,6 @@ func (c *MySqlConnector) PullRecords(`
`818`	`818`	`e := exceptions.NewMySQLUnsupportedBinlogRowValueOptionsError(string(ev.Table.Schema), string(ev.Table.Table))`
`819`	`819`	`c.logger.Error(e.Error())`
`820`	`820`	`return e`
`821`		`- default:`
`822`		`- return fmt.Errorf("unhandled mysql rows event type: %s", event.Header.EventType)`
`823`	`821`	`}`
`824`	`822`	`}`
`825`	`823`	`if event.Header.Timestamp > 0 {`