Skip to content

Commit

Permalink
Skip.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Aug 20, 2024
1 parent 340e08e commit 664f7a5
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions lib/dynamo/message.go
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down

0 comments on commit 664f7a5

Please sign in to comment.