KafkaSource(TiDB)

启动类

connector-source-kafka.jar

com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster

【元信息】kafkaTopic

• 功能：Kafka Source 读取的 TiDB CDC 投递的 Kafka Topic

• 默认值：无，必填

• 值的选择范围：string

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【元信息】kafkaAddr

• 功能：Kafka Source 读取的 Kafka 的地址

• 默认值：无，必填

• 值的选择范围：string

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【元信息】kafkaPort

• 功能：Kafka Source 读取的 Kakfa 的端口

• 默认值：无，必填

• 值的选择范围：int

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【位点信息】timstamp

• 功能：Kafka Source 拉取位点

• 默认值：空

• 值的选择范围：long

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本

【位点信息】forceConsumeBegin

• 功能：Kafka Source 是否强制从 Topic 的起始 offset 进行读取

• 默认值：false

• 值的选择范围：boolean

• 支持的版本：OMS 社区版 3.3.1-CE 及之后版本