fix

tuihub · Oct 6, 2024 · 3b99d2b · 3b99d2b
1 parent 4ad44a7
commit 3b99d2b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/lib/libmq/mq_sql.go b/internal/lib/libmq/mq_sql.go
@@ -32,6 +32,7 @@ func newSQLAdapter(c *conf.Database, loggerAdapter *mqLogger) (*pubSub, error) {
 		}
 		sa = sql.DefaultPostgreSQLSchema{
 			GenerateMessagesTableName: nil,
+			GeneratePayloadType:       nil,
 			SubscribeBatchSize:        0,
 		}
 		oa = sql.DefaultPostgreSQLOffsetsAdapter{