请教大佬们,如何查询changefeed-id落在那个ticdc节点?
ticdc集群部署,至少2个节点,创建一个同步任务,先查询该同步任务是那个ticdc节点执行。
tiup cdc cli changefeed list --pd=http://pd-ip:2379
TiCDC 同步数据的最小单位是表,应该指的是changefeed-id对应的表落在哪个ticdc节点吧?
./cdc cli changefeed query --pd=http://ip:port --changefeed-id ${changefeed-id}里的task_status部分会展示cdc节点表的分布
这个命令查不出changefeed落在那个ticdc节点(没IP信息)
[tidb@tb-center ~]$ tiup cdc cli changefeed query --server=http://10.201.14.2:8300 --changefeed-id=p-to-s
Starting component cdc: /home/tidb/.tiup/components/cdc/v8.5.5/cdc cli changefeed query --server=http://10.201.14.2:8300 --changefeed-id=p-to-s
{
“upstream_id”: 7527859385735025466,
“id”: “p-to-s”,
“keyspace”: “”,
“sink_uri”: “mysql://root:xxxxx@10.201.14.1:4000”,
“config”: {
“memory_quota”: 2147483648,
“case_sensitive”: false,
“force_replicate”: false,
“ignore_ineligible_table”: false,
“check_gc_safe_point”: true,
“enable_sync_point”: false,
“enable_table_monitor”: false,
“bdr_mode”: false,
“sync_point_interval”: 600000000000,
“sync_point_retention”: 86400000000000,
“filter”: {
“rules”: [
“.”
]
},
“mounter”: {
“worker_num”: 16
},
“sink”: {
“delete_only_output_handle_key_columns”: null,
“content_compatible”: null,
“advance_timeout”: 150,
“send_bootstrap_interval_in_sec”: 120,
“send_bootstrap_in_msg_count”: 10000,
“send_bootstrap_to_all_partition”: true,
“send-all-bootstrap-at-start”: false,
“debezium_disable_schema”: false,
“debezium”: {
“output_old_value”: true
},
“open”: {
“output_old_value”: true
}
},
“consistent”: {
“level”: “none”,
“max_log_size”: 64,
“flush_interval”: 2000,
“meta_flush_interval”: 200,
“encoding_worker_num”: 16,
“flush_worker_num”: 8,
“use_file_backend”: false,
“memory_usage”: {
“memory_quota_percentage”: 50
}
},
“scheduler”: {
“enable_table_across_nodes”: false,
“region_threshold”: 100000,
“write_key_threshold”: 0
},
“integrity”: {
“integrity_check_level”: “none”,
“corruption_handle_level”: “warn”
},
“changefeed_error_stuck_duration”: 1800000000000,
“synced_status”: {
“synced_check_interval”: 300,
“checkpoint_interval”: 15
}
},
“create_time”: “2025-11-26 09:30:26.954”,
“start_ts”: 462453437439148037,
“resolved_ts”: 465178446894727170,
“target_ts”: 0,
“checkpoint_tso”: 465178446684749831,
“checkpoint_time”: “2026-03-26 16:49:08.596”,
“state”: “normal”,
“creator_version”: “v8.5.3”,
“task_status”: [
{
“capture_id”: “2d865e12-8b90-42ec-8dec-856af01dddfd”,
“table_ids”: [
186,
246,
10608,
11252,
11738,
11791,
117,
262,
287,
665,
10899,
11472,
11480,
114,
116,
150,
11298,
11412,
244,
10824,
619,
621,
671,
11056,
239,
623,
695,
11450,
260,
654,
661,
10579,
10688,
136,
366,
667,
678,
10594,
10665,
10999,
11270,
233,
253,
11589,
11649,
11802,
11855,
169,
641,
10468,
10875,
130,
322,
699,
731,
167,
201,
614,
703,
11037,
11550,
11813,
306,
617,
625,
728,
11389,
11706,
198,
10540,
11070,
321,
655,
125,
10640,
179,
381,
11211,
683,
712,
737,
10604,
10907,
11442,
11543,
11613,
177,
11644,
135,
698,
11104,
350,
593,
11558,
11618,
172,
134,
378,
690,
11011,
643,
838,
234,
677,
10606,
10702,
11126,
112,
10854,
11042,
11859,
700,
916,
11601,
556,
716,
863,
11234,
170,
672,
10808,
11061,
552,
631,
11398,
11755,
11821,
670,
151,
301,
316,
680,
11434,
701,
11189,
11496,
304,
615,
10987,
11577,
11607,
332,
653,
11219,
11277,
157,
11334,
11663,
334,
669,
156,
240,
342,
717,
10771,
281,
292,
337,
11767,
488,
675,
10456,
10542,
10610,
10680,
11016,
11362,
284,
377,
10536,
11258,
142,
11177,
11356,
11531,
11368,
11743,
263,
298,
343,
345,
11717,
11728,
11857,
192,
319,
11825,
616,
148,
155,
175,
258,
10967,
11672,
11684,
368,
267,
649,
11136,
132,
10559,
11047,
141,
10724,
692,
10659,
11853,
174,
178,
283,
694,
10846,
118,
10929,
11779,
160,
180,
638,
11488,
11569,
353,
706,
11246,
11314,
211,
250,
880,
11093,
124,
720,
10646,
10756,
10956,
11733,
137,
146,
271,
10921,
210,
626,
11464,
704,
10590,
10975,
275,
231,
327,
11374,
11153
]
},
{
“capture_id”: “027ecaf5-39ab-4699-a834-2130fb6cef46”,
“table_ids”: [
163,
647,
11141,
362,
11115,
313,
651,
147,
620,
630,
632,
859,
901,
10585,
11052,
197,
204,
241,
294,
309,
375,
376,
608,
143,
190,
355,
380,
693,
650,
681,
149,
382,
238,
257,
347,
658,
679,
261,
311,
10652,
10738,
652,
11082,
11131,
245,
115,
338,
710,
702,
891,
176,
173,
317,
734,
877,
11867,
954,
11695,
119,
477,
664,
11349,
882,
10628,
203,
235,
291,
722,
10881,
11200,
205,
120,
194,
195,
645,
193,
541,
153,
10462,
144,
161,
209,
325,
348,
691,
10794,
11342,
138,
254,
612,
732,
10948,
11654,
236,
315,
10731,
10870,
133,
166,
668,
736,
895,
255,
289,
639,
687,
851,
296,
531,
709,
10912,
139,
432,
11842,
212,
276,
634,
10602,
279,
352,
660,
628,
881,
188,
273,
282,
624,
11514,
171,
490,
10616,
10744,
340,
897,
11426,
360,
449,
123,
472,
10889,
11283,
11639,
11847,
164,
656,
663,
676,
719,
730,
622,
711,
10583,
11264,
364,
640,
11306,
168,
127,
213,
277,
320,
523,
268,
726,
11165,
126,
357,
613,
708,
121,
181,
331,
724,
10862,
10941,
339,
635,
715,
879,
10716,
252,
264,
372,
633,
10634,
11320,
129,
158,
185,
207,
611,
659,
11223,
248,
547,
707,
714,
836,
889,
242,
370,
637,
191,
374,
673,
11326,
11658,
266,
269,
336,
464,
685,
893,
152,
299,
11523,
696,
154,
159,
662,
689,
899,
10750,
308,
629,
11005,
300,
735,
10570,
10832,
200,
302,
733,
10780,
10816,
11506,
588,
642,
718,
182,
208,
354,
358,
10708,
199,
206,
247,
329,
10696
]
}
]
}
[tidb@tb-center ~]$
没有看到ticdc节点信息
./cdc cli capture list --pd=http://ip:port
查询出capture_id与ticdc节点之间的关系
tiup cdc cli changefeed query这个命令查查看看,再往里查日志
cdc cli changefeed query --server=http://:8300 --changefeed-id=
在返回的 JSON 结果中,关注 task_status 字段。它会列出所有处理此 changefeed 的 capture_id
tdcdc的工作流是这样
比如你创建一个 Changefeed,需要同步 4 张表,这个 Changefeed 被拆分成了 3 个任务(task),均匀的分发到了 TiCDC 集群的 3 个 Capture 节点上,在 TiCDC 对这些数据进行了处理之后,数据同步到了下游的系统。
你这种查询changefeed落到哪个节点是没法查询的。