原始任务(告警太多)清理了,相同配置的任务。
{
"upstream_id": 6965866413841334309,
"namespace": "default",
"id": "ticdc-topic-xxx",
"sink_uri": "kafka://kafka-ip:9092/ticdc-topic-xxx?protocol=canal-json\u0026max-message-bytes=67108864\u0026replication-factor=2\u0026partition-num=8",
"config": {
"memory_quo…
有比较多重试日志 kafka: tried to use a client that was closed,其余就没了
[2025/03/20 09:47:42.013 +08:00] [WARN] [metrics_collector.go:96] ["Get Kafka brokers failed, use historical brokers to collect kafka broker level metrics"] [namespace=default] [changefeed=ticdc-topic-prod-xxxxx] [role=processor] [duration…