com.ververica.cdc.connectors.mysql.source.config

Class MySqlSourceConfig

java.lang.Object

com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig

All Implemented Interfaces:

Serializable

public class MySqlSourceConfig
extends Object
implements Serializable

A MySql Source configuration which is used by MySqlSource.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
int	getConnectionPoolSize()
int	getConnectMaxRetries()
java.time.Duration	getConnectTimeout()
List<String>	getDatabaseList()
io.debezium.config.Configuration	getDbzConfiguration()
Properties	getDbzProperties()
double	getDistributionFactorLower()
double	getDistributionFactorUpper()
int	getFetchSize()
String	getHostname()
Properties	getJdbcProperties()
io.debezium.connector.mysql.MySqlConnectorConfig	getMySqlConnectorConfig()
String	getPassword()
int	getPort()
ServerIdRange	getServerIdRange()
String	getServerTimeZone()
int	getSplitMetaGroupSize()
int	getSplitSize()
StartupOptions	getStartupOptions()
io.debezium.relational.RelationalTableFilters	getTableFilters()
List<String>	getTableList()
String	getUsername()
boolean	isIncludeSchemaChanges()
boolean	isScanNewlyAddedTableEnabled()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getHostname

public String getHostname()

getPort

public int getPort()

getUsername

public String getUsername()

getPassword

public String getPassword()

getDatabaseList

public List<String> getDatabaseList()

getTableList

public List<String> getTableList()

getServerIdRange

@Nullable
public ServerIdRange getServerIdRange()

getStartupOptions

public StartupOptions getStartupOptions()

getSplitSize

public int getSplitSize()

getSplitMetaGroupSize

public int getSplitMetaGroupSize()

getDistributionFactorUpper

public double getDistributionFactorUpper()

getDistributionFactorLower

public double getDistributionFactorLower()

getFetchSize

public int getFetchSize()

getServerTimeZone

public String getServerTimeZone()

getConnectTimeout

public java.time.Duration getConnectTimeout()

getConnectMaxRetries

public int getConnectMaxRetries()

getConnectionPoolSize

public int getConnectionPoolSize()

isIncludeSchemaChanges

public boolean isIncludeSchemaChanges()

isScanNewlyAddedTableEnabled

public boolean isScanNewlyAddedTableEnabled()

getDbzProperties

public Properties getDbzProperties()

getDbzConfiguration

public io.debezium.config.Configuration getDbzConfiguration()

getMySqlConnectorConfig

public io.debezium.connector.mysql.MySqlConnectorConfig getMySqlConnectorConfig()

getTableFilters

public io.debezium.relational.RelationalTableFilters getTableFilters()

getJdbcProperties

public Properties getJdbcProperties()