如何打开这个新特性：TiCDC 同步数据到 Kafka，吞吐从 4000 行每秒提升到 35000 行每秒，复制延迟降低到 2 秒。

🪐 TiDB 技术问题
4

要打开 TiCDC 同步数据到 Kafka 的新特性，您需要按照以下步骤进行操作：

  1. 确保您的 TiCDC 版本是 v4.0.9 或更高版本，因为这个新特性是在这个版本中引入的。
  2. 按照 TiCDC 官方文档中的说明，创建一个 changefeed，将数据同步到 Kafka 中。具体操作步骤可以参考 Replicate Data to Kafka。
  3. 在创建 changefeed 时，您可以通过配置 sink-uri 参数来控制 TiCDC 同步数据到 Kafka 的吞吐量。具体来说，您可以在 sink-uri 参数中添加以下配置项：
kafka.producer.config.bootstrap.servers=<kafka-broker-list>
kafka.producer.config.max.request.size=<max-request-size>

其中，<kafka-broker-list> 是您 Kafka 集群中的 broker 列表，<max-request-size> 是单个 Kafka 消息的最大大小。通过适当调整这两个参数，您可以提高 TiCDC 同步数据到 Kafka 的吞吐量。

需要注意的是，如果您在使用 TiCDC 同步数据到 Kafka 时遇到了问题，可以参考 Troubleshoot TiCDC 中的内容进行故障排除。

1 个赞