Hazelcast Jet CDC PostgresCdcSources

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.cdc.postgres.PostgresCdcSources;

CDC connectors için açıklama şöyle

Open-source

• MySQL

• PostgreSQL

• Debezium.io

Enterprise

• Striim.io

Örnek

Şöyle yaparız

StreamSource<ChangeRecord> source = PostgresCdcSources.postgres("source")
  .setCustomProperty("plugin.name", "pgoutput")
  .setDatabaseAddress("127.0.0.1")
  .setDatabasePort(5432)
  .setDatabaseUser("postgres")
  .setDatabasePassword("root")
  .setDatabaseName("postgres")
  .setTableWhitelist("tblName")
  .build();