Skip to content

Commit 385bef3

Browse files
committed
fix: postgres add heartbeat back
(cherry picked from commit b7e39a0)
1 parent ad002bb commit 385bef3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

connectors-common/postgres-core/src/main/java/io/tapdata/connector/postgres/cdc/config/PostgresDebeziumConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ public Configuration create() {
115115
.with("geometry.schema.name", "io.debezium.postgresql.type.Geometry")
116116
.with("other.type", "io.tapdata.connector.postgres.converters.OtherConverter")
117117
.with("other.schema.name", "io.debezium.postgresql.type.Other")
118-
// .with("heartbeat.interval.ms", 3000)
118+
.with("heartbeat.interval.ms", 3000)
119119
.with("plugin.name", postgresConfig.getLogPluginName())
120120
.with("max.queue.size", postgresConfig.getMaximumQueueSize())
121121
.with("max.batch.size", postgresConfig.getMaximumQueueSize() / 8);

0 commit comments

Comments
 (0)