执行运行脚本没有反应

[heqian1024]

执行运行语句警告，警告偶尔有：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
没有任何其他反应

[xiaoma20082008]

执行运行语句警告，警告偶尔有：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
没有任何其他反应

cfg.properties要写绝对路径

[heqian1024]

还是一样，没有反应，是不是我的配置文件存在问题

运行脚本
java -server -classpath conf/:lib/ com.hellobike.base.tunnel.TunnelLauncher -u false -c /root/tunnel-master/target/AppTunnelService/conf/cfg.properties

我的配置
{
# pg_dump 可执行文件path，如pg_dump在 $PATH 路径下面，则不需配置
"pg_dump_path": "",
"subscribes": [{
# 是否dump 历史数据，如只需要实时数据，可以不配或配置为false，默认false
"dump": false,
# 逻辑复制槽名称，确保唯一
"slotName": "slot_for_kafka",
# pg 连接配置
"pgConnConf": {
"host": "192.168.216.87",
"port": 6432,
"database": "grabdb",
"user": "replica",
"password": "******"
},
# 同步规则配置
"rules": [
{
# 表名匹配，支持通配符
"table": "t_mon_kafka",
# 表的主键配置
# "pks": ["id"],
# kafka topic
"topic": "tunnel.db40t.t_mon_kafka"
}
],
# kafka 连接配置
"kafkaConf": {
"addrs": ["192.168.216.158:9092","192.168.216.157:9092","192.168.200.94:9092"]
}
}]
}

[heqian1024]

另外，我尝试了你们的另一个工具amazonriver，但是发现一个比较严重的问题，丢数据，能不能帮忙通知一下维护人员：
hellobike/amazonriver#16

[xiaoma20082008]

还是一样，没有反应，是不是我的配置文件存在问题

运行脚本
java -server -classpath conf/:lib/ com.hellobike.base.tunnel.TunnelLauncher -u false -c /root/tunnel-master/target/AppTunnelService/conf/cfg.properties

我的配置
{

pg_dump 可执行文件path，如pg_dump在 $PATH 路径下面，则不需配置

"pg_dump_path": "",
"subscribes": [{

是否dump 历史数据，如只需要实时数据，可以不配或配置为false，默认false

"dump": false,

逻辑复制槽名称，确保唯一

"slotName": "slot_for_kafka",

pg 连接配置

"pgConnConf": {
"host": "192.168.216.87",
"port": 6432,
"database": "grabdb",
"user": "replica",
"password": "******"
},

同步规则配置

"rules": [
{

表名匹配，支持通配符

"table": "t_mon_kafka",

表的主键配置

"pks": ["id"],

kafka topic

"topic": "tunnel.db40t.t_mon_kafka"
}
],

kafka 连接配置

"kafkaConf": {
"addrs": ["192.168.216.158:9092","192.168.216.157:9092","192.168.200.94:9092"]
}
}]
}
配置文件要参考这个，只有两行，第一行是你上面的配置（json化之后，格式化成一行），第二行是一个zk地址

[heqian1024]

成功了，谢谢！
以下几个问题请教下：
1、tunnel_zookeeper_address=192.168.216.157:2181 这行配置用来干嘛的，是tunnel单独使用的一个zk吗，我配置的这个是kafka集群的某个zk，会不会有问题，有异常信息：
[2019-06-14 11:16:30.623] [ INFO] [92.168.216.157:2181)] [o.a.z.ClientCnxn ] Opening socket connection to server 192.168.216.157/192.168.216.157:2181. Will not attempt to authenticate using SASL (unknown error)

2、配置文件写成一行的方式不是很友好，会不会考虑优化？
3、目前往kafka只推送修改后数据，能不能考虑下把修改前数据也推送过去，debezuim会将修改前数据推送，但是不稳定，问题太多，想用你们这个工具。
4、这个工具你们内部有在生产上使用吗，我们很想在生产上使用，但是怕有问题，你们后期会维护更新吗？

[huayuanzzb]

关于第二个问题，我增加了yml格式配置文件，可以将配置分为多行，不知是否可以合进来？

[xiaoma20082008]

嗯，线上再用，不过内部是基于apollo的，下个版本会做修改吧！ 发自我的 iPhone 在 2019年6月14日，上午11:05，heqian1024 <[email protected]<mailto:[email protected]>> 写道： 成功了，谢谢！ 以下几个问题请教下： 1、配置文件写成一行的方式不是很友好，会不会考虑优化？ 2、目前往kafka只推送修改后数据，能不能考虑下把修改前数据也推送过去，debezuim会将修改前数据推送，但是不稳定，问题太多，想用你们这个工具。 3、这个工具你们内部有在生产上使用吗，我们很想在生产上使用，但是怕有问题，你们后期会维护更新吗？ — You are receiving this because you commented. Reply to this email directly, view it on GitHub<#5?email_source=notifications&email_token=ACM4B2J5AX2LXEVZFBEGF5DP2MDGPA5CNFSM4HXYHZVKYY3PNVWWK3TUL52HS4DFVREXG43VMVBW63LNMVXHJKTDN5WW2ZLOORPWSZGODXVSSJA#issuecomment-501950756>, or mute the thread<https://github.com/notifications/unsubscribe-auth/ACM4B2JOEYTR35MF3R3VIM3P2MDGPANCNFSM4HXYHZVA>.