Skip to content

Commit fd513c7

Browse files
committed
fix: header converter CloudEvents not supported
1 parent f27517e commit fd513c7

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

stackgres-k8s/src/stream/src/main/java/io/stackgres/stream/jobs/source/AbstractPostgresDebeziumEngineHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@ public <T> CompletableFuture<Void> streamChangeEvents(
132132
try {
133133
engine = DebeziumEngine
134134
.create(
135-
KeyValueHeaderChangeEventFormat.of(format, format, format),
135+
KeyValueHeaderChangeEventFormat.of(format, format, null),
136136
engineBuilderFactory)
137137
.using(props)
138138
.using(new ConnectorCallback() {

0 commit comments

Comments
 (0)