Parameter |
Type |
Required |
Default value |
Description |
|---|---|---|---|---|
| checkpoint | JsonNode | Yes | None | The format is {"clientId": "timestamp", "clientId2": "timestamp"}. |
| clients | JsonNode | Yes | None | The list of store clients. |
| source_receive_queue_size | Integer | No | 8096 | The queue size. |
| store_ask_self_unit | Boolean | No | false | Indicates whether to mask other data. |
| store_connection_timeout_sec | Integer | No | 120 | The store connection timeout period. |
| store_max_retries | Integer | No | 3 | The maximum number of retries to pull data from a store. |
| store_record_sequence_enabled | Boolean | No | true | Specifies whether to enable sequence recording. |
| store_socket_timeout_sec | Integer | No | 120 | The timeout period of store socket connections. |
| store_time_zone | String | No | +08:00 | The time zone of the store from which data is pulled. |
| store_transaction_counter_ignore_exception | Boolean | No | false | Specifies whether to ignore exceptions during transaction calculation. It is a temporary parameter for new features. |
| store_transaction_enabled | Boolean | No | false | Specifies whether to enable sequence numbers for transactions. |
| store_username | String | Yes | None | The password for pulling data from a store, which is the password of the consumer account in oms_cm. |
StoreClient parameters
Parameter |
Type |
Required |
Default value |
Description |
|---|---|---|---|---|
| askSelfUnit | Boolean | No | Subject to the value of the upper-layer parameter | Specifies whether to mask the traffic of other regions. |
| clientId | String | Yes | None | The unique ID of the store client. |
| clusterManagerUrl | String | Yes | None | The value is in the format of "address of the cluster manager.manager.host". |
| connectionTimeoutSec | Integer | No | Subject to the value of the upper-layer parameter | The timeout period of client connections. |
| filterConditions | String | Yes | No | The store whitelist. |
| logicDatabase | String | No | None | The name of the logical database. |
| logicTable | String | No | None | The name of the logical table. |
| maxRetries | Integer | No | Subject to the value of the upper-layer parameter | The maximum number of connection retries. |
| password | String | No | Subject to the value of the upper-layer parameter | The password for accessing Binlog. |
| socketTimeoutSec | Integer | No | Subject to the value of the upper-layer parameter | The timeout period of client responses. |
| subtopic | String | Yes | None | The subtopic. |
| transactionEnabled | Boolean | No | Subject to the value of the upper-layer parameter | Specifies whether to sort transactions by sequence number. |
| transactionCounterExceptionIgnore | Boolean | No | Subject to the value of the upper-layer parameter | Specifies whether to ignore transaction sorting exceptions. |
| timestamp | Integer | Yes | None | The timestamp. |
| username | String | No | Subject to the value of the upper-layer parameter | The username for accessing Binlog. |