tiup怎么新添加一个drainer节点，且配置为kafka？

[hanson]

tidb v4.0.0

目前tidb中已有一个drainer节点，同步至下游mysql。现想再增加一个drainer节点，同步至kafka，请问使用tiup如何操作？

文档中看到drainer配置kafka还是使用的ansible的方式，没有看到有tiup相关的操作示例

[来了老弟]

你好，

在 tiup 部署集群中有所体现。https://docs.pingcap.com/zh/tidb/v4.0/tidb-binlog-deployment-topology

[hanson]

谢谢，节点已经加好了
还有个问题，就是现在直接发送给kafka的数据，有乱码，编码有问题，这个怎么解决呢？

[来了老弟]

看下下面的帖子是否有帮助：

• Drainer下放给kafka的binlog日志乱码

[hanson]

binlog.proto 这个代码怎么使用呢？

[来了老弟]

你好，此部分一般为用户自行开发，这边研发同学提供了一些使用方式，可以参考下：

• binlog kafka 消费端 示例（java）：https://github.com/pingcap/tidb-tools/tree/master/tidb-binlog/driver/example/kafkaReader
• binlog kafka 消费端 示例（go）：https://github.com/pingcap/tidb-tools/tree/master/tidb-binlog/driver/example/print

[hanson]

好的，我这边先研究一下

[来了老弟]