Postgres source will produce its own schema; disable autogen (#198)

ConduitIO · Sep 7, 2024 · 8518213 · 8518213
1 parent 745bef3
commit 8518213
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/source.go b/source.go
@@ -22,6 +22,7 @@ import (
 
 	"github.com/conduitio/conduit-commons/config"
 	"github.com/conduitio/conduit-commons/csync"
+	"github.com/conduitio/conduit-commons/lang"
 	"github.com/conduitio/conduit-commons/opencdc"
 	"github.com/conduitio/conduit-connector-postgres/source"
 	"github.com/conduitio/conduit-connector-postgres/source/cpool"
@@ -46,7 +47,13 @@ func NewSource() sdk.Source {
 		&Source{
 			tableKeys: make(map[string]string),
 		},
-		sdk.DefaultSourceMiddleware()...,
+		sdk.DefaultSourceMiddleware(
+			// disable schema extraction by default, postgres will build its own schema
+			sdk.SourceWithSchemaExtractionConfig{
+				PayloadEnabled: lang.Ptr(false),
+				KeyEnabled:     lang.Ptr(false),
+			},
+		)...,
 	)
 }