Uses of Class
com.hazelcast.jet.cdc.postgres.PostgresCdcSources.Builder
Package | Description |
---|---|
com.hazelcast.jet.cdc.postgres |
Contains connectors for change data capture events from PostgreSQL
databases.
|
-
Uses of PostgresCdcSources.Builder in com.hazelcast.jet.cdc.postgres
Methods in com.hazelcast.jet.cdc.postgres that return PostgresCdcSources.Builder Modifier and Type Method Description static PostgresCdcSources.Builder
PostgresCdcSources. postgres(String name)
Creates a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet.PostgresCdcSources.Builder
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
PostgresCdcSources.Builder. setCommitPeriod(long milliseconds)
Specifies how often the connector should confirm processed offsets to the Postgres database's replication slot.PostgresCdcSources.Builder
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
PostgresCdcSources.Builder. setDatabaseAddress(String address)
IP address or hostname of the database server, has to be specified.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setDatabaseName(String dbName)
The name of the PostgreSQL database from which to stream the changes.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setDatabasePassword(String password)
Database user password for connecting to the database server.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setDatabasePort(int port)
Optional port number of the database server, if unspecified defaults to the database specific default port (5432).PostgresCdcSources.Builder
PostgresCdcSources.Builder. setDatabaseUser(String user)
Database user for connecting to the database server.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setLogicalDecodingPlugIn(String pluginName)
The name of the @see Postgres logical decoding plug-in installed on the server.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setPublicationName(String publicationName)
The name of the Postgres publication that will be used for CDC purposes.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setReconnectBehavior(RetryStrategy retryStrategy)
Specifies how the connector should behave when it detects that the backing database has been shut dow.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setReplicationSlotDropOnStop(boolean dropOnStop)
Whether or not to drop the logical replication slot when the connector disconnects cleanly.PostgresCdcSources.Builder
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
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
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
PostgresCdcSources.Builder. setShouldStateBeResetOnReconnect(boolean reset)
Specifies if the source's state should be kept or discarded during reconnect attempts to the database.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setSslCertificateFile(String file)
Specifies the (path to the) file containing the SSL Certificate for the database client.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setSslKeyFile(String file)
Specifies the (path to the) file containing the SSL private key of the database client.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setSslKeyFilePassword(String password)
Specifies the password to be used to access the SSL key file, if specified.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setSslMode(String mode)
Specifies whether to use an encrypted connection to the database.PostgresCdcSources.Builder
PostgresCdcSources.Builder. setSslRootCertificateFile(String file)
Specifies the file containing containing SSL certificate authority (CA) certificate(s).PostgresCdcSources.Builder
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
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.