Adding default case.

artie-labs · Oct 17, 2024 · 06300e6 · 06300e6
1 parent d6d90bf
commit 06300e6
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/cdc/util/relational_event.go b/lib/cdc/util/relational_event.go
@@ -108,6 +108,8 @@ func (s *SchemaEventPayload) GetData(pkMap map[string]any, tc kafkalib.TopicConf
 		}
 		retMap[constants.DeleteColumnMarker] = false
 		retMap[constants.OnlySetDeleteColumnMarker] = false
+	default:
+		return nil, fmt.Errorf("unknown operation %q", s.Operation())
 	}
 
 	if tc.IncludeArtieUpdatedAt {