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
.