ticdc怎么配置rocket mq 的 sink url ？

xfworld · 2022 年3 月 9 日 03:54

目前尚未有sink 服务能直接支持的，可自行开发完成这个接入动作
另外，目前支持的协议可以给你参考下：

pingcap/tiflow/blob/master/docs/design/2020-11-04-ticdc-protocol-list.md

# TiCDC 支持的消息队列输出协议指南

## A Guide to the Protocols Supported by TiCDC

# Overview 概要

TiCDC 目前支持 4 种消息队列输出协议。“协议”这里指将 TiDB 的数据变化输出到 Kafka 或其他消息队列时的序列化格式，以及其他配套的策略（如时序、消息分片）等。

The current version of TiCDC supports four protocols for writing to a message queue. A “protocol” here refers to the serialization scheme together with relevant policies (such as message ordering guarantees and partitioning rules).

所有的协议均能保证，如果忽略重复消息，在**同一 Partition 中，同一数据表中**的改动，按照 commit 时间戳顺序输出。重复消息在 TiCDC 与 TiKV 的连接中断重连，或数据表在 TiCDC 节点迁移的时候**可能发生**。

All protocols guarantee that, with duplicate messages ignored, **in any given partition**, **data changes** to **a given table** are ordered by their commit timestamps. Duplication **can** happen when a TiCDC node re-establishes connection with TiKV or when the replication task of a table is being migrated across TiCDC nodes.

除了 Avro 协议之外，所有其他协议均可以输出行变更之前的旧值 (old value)。

Except for Avro, all protocols support outputting the old value before the change.

# Protocols 分协议介绍

该文件已被截断。显示原文

还有其他的需求的，可以参考这篇：