消费drainer的kafka消息报错

为提高效率,提问时请提供以下信息,问题描述清晰可优先响应。

  • 【TiDB 版本】:v4.0.7
  • 【问题描述】:

我这里使用drainer进kafka,然后使用你们提供的小工具去解析kafka binlog的时候,报错:panic: field slave.binlog.Binlog.type has invalid type: got slave_binlog.BinlogType, want pointer,看了一下,应该是pb的String()有点问题,不知怎么解决。

你好,请问具体使用的哪个工具? 辛苦提供详细日志我们一起看下。

同样的问题 https://github.com/pingcap/tidb-tools/tree/master/tidb-binlog/driver/example/print

1 个赞