changfeed未接收到TiCDC 的请求

[TiDBer_yyy]

下游Kafka集群是3节点，默认配置是3，这里指定replication-factor=2

感觉还是没有解决changefeed没有接收到request的问题。

[LingJin (3AceShowHand)]

@TiDBer_yangky

[2022/03/24 15:03:19.988 +08:00] [INFO] [client.go:779] [“ start new request ”] [request=“{“header”:{“cluster_id”:7009090993806118458,“ticdc_version”:“5.0.4”},“region_id”:98161,“region_epoch”:{“conf_ver”:5,“version”:51},“checkpoint_ts”:432040941912588289,“start_key”:“bURETEpvYkH/ZP9kSWR4TGn/c3T/AAAAAAD/AAAA9wAAAAD/AAAAbAAAAAD7”,“end_key”:“bURETEpvYkH/ZP9kSWR4TGn/c3T/AAAAAAD/AAAA9wAAAAD/AAAAbQAAAAD7”,“request_id”:4344,“Request”:null}”] [addr=localhost:20160]
[2022/03/24 15:03:20.233 +08:00] [INFO] [client.go:1258] [“region state entry will be replaced because received message of newer requestID”] [regionID=98161] [oldRequestID=4342] [requestID=4344] [addr=localhost:20160]
[2022/03/24 15:09:31.319 +08:00] [INFO] [client.go:959] [“EventFeed disconnected”] [regionID=98161] [requestID=4343] [span=“[6d44444c4a6f624cff69ff737400000000ff0000f90000000000ff00006c0000000000fa, 6d44444c4a6f624cff69ff737400000000ff0000f90000000000ff00006d0000000000fa)”] [checkpoint=432041039194226689] [error=“[CDC:ErrEventFeedEventError]not_leader:<region_id:98161 > “]
[2022/03/24 15:09:31.319 +08:00] [INFO] [client.go:959] [“EventFeed disconnected”] [regionID=98161] [requestID=4344] [span=”[6d44444c4a6f6241ff64ff644964784c69ff7374ff0000000000ff000000f700000000ff0000006c00000000fb, 6d44444c4a6f6241ff64ff644964784c69ff7374ff0000000000ff000000f700000000ff0000006d00000000fb)”] [checkpoint=432041039194226689] [error="[CDC:ErrEventFeedEventError]not_leader:<region_id:98161 > “]
[2022/03/24 15:09:31.319 +08:00] [INFO] [region_range_lock.go:370] [“unlocked range”] [lockID=22] [regionID=98161]

这是内部的 request，从 TiCDC 发往 TiKV，并且有返回 response 说当前 region 不是 leader。

changefeed没有接收到request的问题。changefeed 不需要去收 request。

建议多重试一下。

[TiDBer_yyy]

重试是重新创建cdc，还是发起新的dml？

大佬，重新上传日志，辛苦有时间看一下。

cdc_1_tmp.log.0 (142.0 KB)

复测之后发现：sink-url 中去掉partition-num 参数：

tiup ctl:v5.0.4 cdc changefeed create --pd=http://127.0.0.1:2379 --changefeed-id="test-kafka-canal-json" --sink-uri="kafka://127.0.0.1:9092/kafka-canal-json-test-242343?protocol=canal-json&max-message-bytes=67108864&replication-factor=2" --config kafka-canal-json-changefeed.toml

下游kafka会同步消息。

[lxzkenney (MR.Li)]

我们的使用方式和你一样，没遇到过你说的问题。 tidb -->ticdc ->kafka --flink

[TiDBer_yyy]

版本可能不一样？测了几次，问题比较奇怪。
还有一个truncate 表 后，revosled-ts 时间戳不在增加。