KafkaSource (TiDB)

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.