Uses of Class
com.hazelcast.jet.cdc.mysql.MySqlCdcSources.Builder
Packages that use MySqlCdcSources.Builder
Package
Description
Contains connectors for change data capture events from MySQL
databases.
-
Uses of MySqlCdcSources.Builder in com.hazelcast.jet.cdc.mysql
Methods in com.hazelcast.jet.cdc.mysql that return MySqlCdcSources.BuilderModifier and TypeMethodDescriptionstatic MySqlCdcSources.BuilderCreates a CDC source that streams change data from a MySQL database to Hazelcast Jet.MySqlCdcSources.Builder.setClusterName(String cluster) Logical name that identifies and provides a namespace for the particular database server/cluster being monitored.MySqlCdcSources.Builder.setColumnBlacklist(String... columnNameRegExps) Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values.MySqlCdcSources.Builder.setCustomProperty(String key, String value) Can be used to set any property not explicitly covered by other methods or to override internal properties.MySqlCdcSources.Builder.setDatabaseAddress(String address) IP address or hostname of the database server, has to be specified.MySqlCdcSources.Builder.setDatabaseBlacklist(String... dbNameRegExps) Optional regular expressions that match database names to be excluded from monitoring; any database name not included in the blacklist will be monitored.MySqlCdcSources.Builder.setDatabaseClientId(int clientId) A numeric ID of this database client, which must be unique across all currently-running database processes in the MySQL cluster.MySqlCdcSources.Builder.setDatabasePassword(String password) Database user password for connecting to the database server.MySqlCdcSources.Builder.setDatabasePort(int port) Optional port number of the database server, if unspecified defaults to the database specific default port (3306).MySqlCdcSources.Builder.setDatabaseUser(String user) Database user for connecting to the database server.MySqlCdcSources.Builder.setDatabaseWhitelist(String... dbNameRegExps) Optional regular expressions that match database names to be monitored; any database name not included in the whitelist will be excluded from monitoring.MySqlCdcSources.Builder.setReconnectBehavior(RetryStrategy retryStrategy) Specifies how the source should behave when it detects that the backing database has been shut down (read class javadoc for details and special cases).MySqlCdcSources.Builder.setShouldStateBeResetOnReconnect(boolean reset) Specifies if the source's state should be kept or discarded during reconnect attempts to the database.MySqlCdcSources.Builder.setSslKeystoreFile(String file) Specifies the (path to the) Java keystore file containing the database client certificate and private key.MySqlCdcSources.Builder.setSslKeystorePassword(String password) Password to access the private key from any specified keystore files.MySqlCdcSources.Builder.setSslMode(String mode) Specifies whether to use an encrypted connection to the database.MySqlCdcSources.Builder.setSslTruststoreFile(String file) Specifies the (path to the) Java truststore file containing the collection of trusted CA certificates.MySqlCdcSources.Builder.setSslTruststorePassword(String password) Password to unlock any specified truststore.MySqlCdcSources.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.MySqlCdcSources.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.