---
title: "KafkaSource(TiDB) | OceanBase 文档中心"
description: KafkaSource(TiDB) 启动类 connector-source-kafka.jar com.oceanbase.oms.connector.source.kafka.KafkaSourceBooster 【元信息】kafkaTopic 功能：Kafka Source 读取的 TiDB CDC 投递的 K…
---
切换语言

- 中文站 - 简体中文
- International - English
- 日本站 - 日本語

文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*L03BS6f-o40AAAAAAAAAAAAADiGDAQ/original) 迁移服务 OMSV 4.2.8 社区版

# KafkaSource(TiDB)

更新时间：2026-04-14 15:40:47

[编辑](https://github.com/oceanbase/oms-doc/edit/V4.2.8/zh-CN/900.o-m-manual/400.components/500.component-parameters/300.source-plugin/500.kafka-source.md)  

## 启动类

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 及之后版本

 上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线