[Debezium] Supporting more types (#872)

artie-labs · Sep 4, 2024 · a89be8f · a89be8f
1 parent 836af1e
commit a89be8f
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/lib/debezium/schema.go b/lib/debezium/schema.go
@@ -83,7 +83,7 @@ func (f Field) GetScaleAndPrecision() (int32, *int32, error) {
 
 func (f Field) ToValueConverter() converters.ValueConverter {
 	switch f.DebeziumType {
-	case UUID:
+	case UUID, Enum:
 		return converters.StringPassthrough{}
 	case DateTimeWithTimezone:
 		return converters.DateTimeWithTimezone{}

diff --git a/lib/debezium/schema_test.go b/lib/debezium/schema_test.go
@@ -115,8 +115,15 @@ func TestField_ToKindDetails(t *testing.T) {
 		assert.Equal(t, typing.String, Field{Type: Bytes}.ToKindDetails())
 	}
 	{
-		// UUID
-		assert.Equal(t, typing.String, Field{DebeziumType: UUID, Type: String}.ToKindDetails())
+		// String passthrough
+		{
+			// UUID
+			assert.Equal(t, typing.String, Field{DebeziumType: UUID, Type: String}.ToKindDetails())
+		}
+		{
+			// Enum
+			assert.Equal(t, typing.String, Field{DebeziumType: Enum, Type: String}.ToKindDetails())
+		}
 	}
 	{
 		// Structs