LogProxySource

2024-04-18 03:40:56  Updated

Starter class

logproxy-source.jar

com.oceanbase.oms.connector.source.logproxy.LogProxySourceBooster

[Metadata] logproxy.address

  • Description: specifies the address of the LogProxy.

  • Default value: None. This parameter is required.

  • Value type: String.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[Metadata] username

  • Description: specifies the username.

  • Default value: None.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[Metadata] password

  • Description: specifies the password.

  • Default value: None.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[Metadata] dbType

  • Description: specifies the type of the database.

  • Default value: None. This parameter is required.

  • Value range: The value of DbTypeEnum.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[Checkpoint information] checkpoint

  • Description: specifies the checkpoint in JSON format. The key is logproxy-client-id and the value is the start timestamp.

  • Default value: None. This parameter is required.

  • Value range:

    { "clientId": "12345" }

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[LogProxy parameters] client.id

  • Description: specifies the user defined client ID (ClientConf.USER_DEFINED_CLIENTID).

  • Default value: None.

  • Value type: String.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[LogProxy parameters] table.white.list

  • Description: specifies the whitelist of tables, the format of which is the same as that in the store.

  • Default value: None. This parameter is required.

  • Value type: String.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[LogProxy parameters] oceanbase.cluster.url

  • Description: specifies the instance URL in an OceanBase cluster.

  • Default value: None. This parameter is required.

  • Value type: String.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[LogProxy parameters] wait.queue.size

  • Description: specifies the transfer queue size (ClientConf.TRANSFER_QUEUE_SIZE).

  • Default value: None.

  • Value type: int.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[LogProxy parameters] properties

  • Description: specifies the ObReaderConfig parameter.

  • Default value: None.

  • Value type: JSON.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[DDL] ignoreDdl

  • Description: specifies whether to ignore DDL statements.

  • Default value: true.

  • Valid values: true and false.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

[Transaction splitting] splitThreshold

  • Description: specifies the threshold for splitting a large transaction.

  • Default value: 128.

  • Value type: int.

  • Supported version: OMS Community Edition V3.3.1-CE and later.

sourceBatchMemorySize

  • Description: specifies the maximum number of records for batch execution (recordBatch) in a transaction. The value is set based on the JVM memory. A transaction will be split for synchronization when either recordBatch or recordBatch is reached.

  • Default value: 4194304, in bytes.

  • Value type: int.

  • Supported version: OMS Community Edition V4.1.1-CE and later.

Contact Us