cdc报错:[CDC:ErrKafkaNewSaramaProducer]kafka:

tiup/main.go at master · pingcap/tiup (github.com)

tiup 宿主机,会存有各个组件的 binary,它直接调用这个 binary,执行相应的命令。也就是说,发出命令的是 tiup 宿主机,而不是被放置在某一个远端的 cdc。

至于访问 kafka,这是在 tiflow/sink.go at master · pingcap/tiflow (github.com)

当执行 cdc cli changefeed create --sink-uri="kafka://xxxx" 的时候,cli 会调用这部分代码。

tiup ctl:vxxxx cdc 其实就是在执行 cdc cli.

1 个赞