diff --git a/lib/dynamo/message.go b/lib/dynamo/message.go
index 9cf760ef..ef0355b0 100644
--- a/lib/dynamo/message.go
+++ b/lib/dynamo/message.go
@@ -106,6 +106,10 @@ func (m *Message) artieMessage() *util.SchemaEventPayload {
 	if len(m.afterSchema) > 0 {
 		var fields []debezium.Field
 		for colName, fieldType := range m.afterSchema {
+			if fieldType == "" {
+				continue
+			}
+			
 			fields = append(fields, debezium.Field{
 				Type:      fieldType,
 				Optional:  true,