source-mysql: Ignore RowsQueryEvents

estuary · Feb 28, 2024 · 7e1970a · 7e1970a
1 parent e4a6fc2
commit 7e1970a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/source-mysql/replication.go b/source-mysql/replication.go
@@ -419,6 +419,8 @@ func (rs *mysqlReplicationStream) run(ctx context.Context) error {
 			} else {
 				logrus.WithField("event", event.Header.EventType.String()).Debug("Generic Event")
 			}
+		case *replication.RowsQueryEvent:
+			logrus.WithField("query", string(data.Query)).Debug("ignoring Rows Query Event")
 		default:
 			return fmt.Errorf("unhandled event type: %q", event.Header.EventType)
 		}