Starter class
connector-source-kafka.jar
com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster
[Metadata] kafkaTopic
Description: specifies the Kafka topic from which Kafka Source reads the incremental data delivered by TiCDC.
Default value: None. This parameter is required.
Value type: String.
Supported version: OMS Community Edition V3.3.1-CE and later.
[Metadata] kafkaAddr
Description: specifies the Kafka address read by the Kafka Source.
Default value: None. This parameter is required.
Value type: String.
Supported version: OMS Community Edition V3.3.1-CE and later.
[Metadata] kafkaPort
Description: specifies the Kafka port read by the Kafka Source.
Default value: None. This parameter is required.
Value type: int.
Supported version: OMS Community Edition V3.3.1-CE and later.
[Checkpoint information] timestamp
Description: specifies the checkpoint when data is pulled by the Kafka Source.
Default value: Null.
Value type: long
Supported version: OMS Community Edition V3.3.1-CE and later.
[Checkpoint information] forceConsumeBegin
Description: specifies whether the Kafka Source forcibly reads data from the start offset of the topic.
Default value: false.
Value type: Boolean.
Supported version: OMS Community Edition V3.3.1-CE and later.
