Uses of Class
com.hazelcast.jet.cdc.postgres.PostgresCdcSources.Builder
Package
Description
Contains connectors for change data capture events from PostgreSQL
databases.
-
Uses of PostgresCdcSources.Builder in com.hazelcast.jet.cdc.postgres
Modifier and TypeMethodDescriptionstatic PostgresCdcSources.Builder
Creates a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet.PostgresCdcSources.Builder.setColumnBlacklist
(String... columnNameRegExps) Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values.PostgresCdcSources.Builder.setCommitPeriod
(long milliseconds) Specifies how often the connector should confirm processed offsets to the Postgres database's replication slot.PostgresCdcSources.Builder.setCustomProperty
(String key, String value) Can be used to set any property not explicitly covered by other methods or to override internal properties.PostgresCdcSources.Builder.setCustomSnapshotter
(Class<?> snapshotterClass) Custom snapshotter that will be used by the connector.PostgresCdcSources.Builder.setDatabaseAddress
(String address) IP address or hostname of the database server, has to be specified.PostgresCdcSources.Builder.setDatabaseName
(String dbName) The name of the PostgreSQL database from which to stream the changes.PostgresCdcSources.Builder.setDatabasePassword
(String password) Database user password for connecting to the database server.PostgresCdcSources.Builder.setDatabasePort
(int port) Optional port number of the database server, if unspecified defaults to the database specific default port (5432).PostgresCdcSources.Builder.setDatabaseUser
(String user) Database user for connecting to the database server.PostgresCdcSources.Builder.setLogicalDecodingPlugIn
(String pluginName) The name of the @see Postgres logical decoding plug-in installed on the server.PostgresCdcSources.Builder.setPublicationName
(String publicationName) The name of the Postgres publication that will be used for CDC purposes.PostgresCdcSources.Builder.setReconnectBehavior
(RetryStrategy retryStrategy) Specifies how the connector should behave when it detects that the backing database has been shut dow.PostgresCdcSources.Builder.setReplicationSlotDropOnStop
(boolean dropOnStop) Whether or not to drop the logical replication slot when the connector disconnects cleanly.PostgresCdcSources.Builder.setReplicationSlotName
(String slotName) The name of the @see Postgres logical decoding slot (also called "replication slot") created for streaming changes from a plug-in and database instance.PostgresCdcSources.Builder.setSchemaBlacklist
(String... schemaNameRegExps) Optional regular expressions that match schema names to be excluded from monitoring ("schema" is used here to denote logical groups of tables).PostgresCdcSources.Builder.setSchemaWhitelist
(String... schemaNameRegExps) Optional regular expressions that match schema names to be monitored ("schema" is used here to denote logical groups of tables).PostgresCdcSources.Builder.setShouldStateBeResetOnReconnect
(boolean reset) Specifies if the source's state should be kept or discarded during reconnect attempts to the database.PostgresCdcSources.Builder.setSnapshotMode
(PostgresCdcSources.PostgresSnapshotMode snapshotMode) Snapshot mode that will be used by the connector.PostgresCdcSources.Builder.setSslCertificateFile
(String file) Specifies the (path to the) file containing the SSL Certificate for the database client.PostgresCdcSources.Builder.setSslKeyFile
(String file) Specifies the (path to the) file containing the SSL private key of the database client.PostgresCdcSources.Builder.setSslKeyFilePassword
(String password) Specifies the password to be used to access the SSL key file, if specified.PostgresCdcSources.Builder.setSslMode
(String mode) Specifies whether to use an encrypted connection to the database.PostgresCdcSources.Builder.setSslRootCertificateFile
(String file) Specifies the file containing containing SSL certificate authority (CA) certificate(s).PostgresCdcSources.Builder.setTableBlacklist
(String... tableNameRegExps) Optional regular expressions that match fully-qualified table identifiers for tables to be excluded from monitoring; any table not included in the blacklist will be monitored.PostgresCdcSources.Builder.setTableWhitelist
(String... tableNameRegExps) Optional regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the whitelist will be excluded from monitoring.