Data Loss in flinkTicdc Reading

This topic has been translated from a Chinese forum by GPT and might contain errors.

Original topic: flinkTicdc 读取数据丢失

| username: TiDBer_GtY4TZQh

[TiDB Usage Environment]
Production Environment

[TiDB Version]

[Encountered Problem]
When Flink TiCDC reads the TiDB table and StartupMode uses LATEST_OFFSET, the Flink job crashes. Upon restarting the job using checkpoint, data is lost during the downtime.

| username: xfworld | Original post link

Flink CDC is not a product of the TiDB community.

You can go to GitHub - apache/flink-cdc: Flink CDC is a streaming data integration tool to submit an issue…

I recommend using TiCDC to connect to Kafka, and then using Flink to connect to Kafka… This ecosystem will be more stable and comprehensive…

| username: system | Original post link

This topic was automatically closed 60 days after the last reply. New replies are no longer allowed.