[doc] fix errors in PostgresParallelSourceExample (#2324)

(cherry picked from commit 6c2fe08af7)
2 years ago · 0026ddde16
parent ef7f0f5259
commit 0026ddde16
1 changed files with 1 additions and 1 deletions
--- a/docs/content/connectors/postgres-cdc.md
+++ b/docs/content/connectors/postgres-cdc.md
@ -429,7 +429,7 @@ public class PostgresParallelSourceExample {
                new JsonDebeziumDeserializationSchema();
        JdbcIncrementalSource<String> postgresIncrementalSource =
-                new PostgresSourceBuilder<String>()
+                PostgresSourceBuilder.PostgresIncrementalSource.<String>builder()
                        .hostname("localhost")
                        .port(5432)
                        .database("postgres")