hellobike/tunnel

PG数据同步工具（Java实现）

tunnel's Issues

代码注释用词错误

在es.md和kafka.md中都有一行代码注释，我想应该是直到，而不是知道

# 错误重试配置,0为不重试,-1会一直重试知道成功

支持多数据库同步吗？

我的需求是将pg数据库中的表同步到es中（通过kafka），现在已经传到kafka了，但是看到传过去的信息中没有数据库的信息，才想起来我们在配置文件中只配置了一个数据库，不知道是否支持多数据库呢？如果支持，怎么从kafka中获取到这个信息呢？有哪位大神知道的话，请指点一下我

请问是否可以提pull request

我们最近也在测试这个工具, 也遇到了单行配置文件不友好和 #6 一样的问题, 我们在自己fork的分支已做了相应的修改. 请问是否可以将这些修改merge进来? 如果可以, 应该怎么做?

执行运行脚本没有反应

执行运行语句警告，警告偶尔有：java -server -classpath conf/:lib/ com.hellobike.base.tunnel.TunnelLauncher -u false -c cfg.properties
警告信息：
[2019-06-13 18:36:47.385] [ WARN] [ main] [c.h.b.t.TunnelLauncher ] config is null at first setup
没有任何其他反应

采集pg到adb

请问楼主的这个代码有性能测试指标吗 ，延时是多少，大量数据

请问这个产品有在更新吗？

java.lang.ArrayIndexOutOfBoundsException: 1372

正常运行一段时间后报错，异常信息如下：

java.lang.ArrayIndexOutOfBoundsException: 1372
at com.hellobike.base.tunnel.parse.EventParser$Lexer.current(EventParser.java:178) ~[tunnel-server-1.0.0-SNAPSHOT.jar:?]
at com.hellobike.base.tunnel.parse.EventParser.parseValue(EventParser.java:129) ~[tunnel-server-1.0.0-SNAPSHOT.jar:?]
at com.hellobike.base.tunnel.parse.EventParser.parseEvent(EventParser.java:100) ~[tunnel-server-1.0.0-SNAPSHOT.jar:?]
at com.hellobike.base.tunnel.parse.EventParser.parse(EventParser.java:62) ~[tunnel-server-1.0.0-SNAPSHOT.jar:?]
at com.hellobike.base.tunnel.TunnelServer.receiveStream(TunnelServer.java:173) ~[tunnel-server-1.0.0-SNAPSHOT.jar:?]
at com.hellobike.base.tunnel.TunnelServer.access$900(TunnelServer.java:43) ~[tunnel-server-1.0.0-SNAPSHOT.jar:?]
at com.hellobike.base.tunnel.TunnelServer$ReceiveTask.run(TunnelServer.java:236) ~[tunnel-server-1.0.0-SNAPSHOT.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202-ea]
[2019-06-14 15:13:32.471] [ INFO] [ReceiveThread-tunnel] [c.h.b.t.TunnelServer ] GetRplConnection success,slot:tunnel
[2019-06-14 15:13:32.473] [ INFO] [ReceiveThread-tunnel] [c.h.b.t.TunnelServer ] GetRplStream success,slot:tunnel
[2019-06-14 15:13:32.473] [ INFO] [ReceiveThread-tunnel] [c.h.b.t.TunnelServer ] recover logical replication success,slot:tunnel,cost:12ms
[2019-06-14 15:13:34.481] [ WARN] [ReceiveThread-tunnel] [c.h.b.t.TunnelServer ] receive msg failure,try to recover.
java.lang.ArrayIndexOutOfBoundsException: null