Equent

The message formats for Source and sink do not correspond

2

I want to synchronize Redis operations from source to kafka and hand over sink to write back to another Redis. But I found that the message format sent by source...

如果sql中一个字符串内含有“;\n”那怎么办？ ```go bytes, err := common.ReadFile(table) common.AssertNil(err) sqlStr := common.BytesToString(bytes) sqls := strings.Split(sqlStr, ";\n") // here!!! for _, sql := range sqls { if sql != "" { _, _...

perf(log): 优化debug日志输出性能

14

- 在调试模式下条件性地输出 debug 日志，减少不必要的日志打印 issue：https://github.com/aceld/zinx/issues/366

大量CPU时间被耗费在日志输出中

4

  可能需要对这类日志输出进行限制，防止无效日志计算