diff --git a/sources/mongo/change_event.go b/sources/mongo/change_event.go index fa99fed4..9cb73c68 100644 --- a/sources/mongo/change_event.go +++ b/sources/mongo/change_event.go @@ -93,7 +93,6 @@ func (c ChangeEvent) getFullDocument() (bson.M, error) { } func (c ChangeEvent) ToMessage() (*Message, error) { - switch c.operationType { case "delete": // TODO: Think about providing the `before` row for a deleted event.