Hazelcast Jet DebeziumCdcSources Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.cdc.DebeziumCdcSources;

Örnek

Şöyle yaparız

StreamSource<ChangeRecord> source = DebeziumCdcSources
  .debezium("postgres", PostgresConnector.class)
  .setProperty("database.server.name",...)
  .setProperty("database.hostname", ...)
  .setProperty("database.port", ...)
  .setProperty("database.user", ...)
  .setProperty("database.password", ...)
  .setProperty("database.dbname", ...)
  .setProperty("table.whitelist", ...)
  .build();


Pipeline pipeline = Pipeline.create();
pipeline.readFrom(source)
  .withNativeTimestamps(1)
  .writeTo(Sinks.list("no_pk"));