canal_mysql_nosql_sync issues

HA模式启动报错

4

![image](https://user-images.githubusercontent.com/74863263/100597326-bf7efe00-3316-11eb-8727-8fae755bed99.png) 请问下这个到底是哪个连接问题啊？里面就是mq,mongo的账号，我看密码都是对的呀 .canal server部署的是2个HA模式，这个client不可以同时启动2个吗？

dba7788

导致服务端 canal.instance.filter.regex 失效

5

connector.subscribe(".*\\..*"); 哥把这句去掉吧会导致服务端的配置失效或者你这里面加一个配置读取吧

kobeng

设置redis.pass了，报 NOAUTH Authentication required.

2

connect error! Exception in thread "main" redis.clients.jedis.exceptions.JedisDataException: NOAUTH Authentication required. at redis.clients.jedis.Protocol.processError(Protocol.java:127) at redis.clients.jedis.Protocol.process(Protocol.java:161) at redis.clients.jedis.Protocol.read(Protocol.java:215) at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:340) at redis.clients.jedis.Connection.getIntegerReply(Connection.java:265) at redis.clients.jedis.Jedis.rpush(Jedis.java:865) at canal.client.redis.push_redis(redis.java:37) at canal.client.CanalClientTest.printEntry(CanalClientTest.java:319) at canal.client.CanalClientTest.main(CanalClientTest.java:242)

ktzhush

乱码问题

1

你好，我按照你那个例子进行测试，print和写入mq的数据中文都是乱码"???" 我server端配置的canal.instance.connectionCharset = UTF-8 数据库db和表也都是utf8，但是client端出来的中文都是乱码，请问还需要哪里配置吗？

GuangbinMu

请问如何编译您这个项目

1

不好意思我不是搞java的如何根据源码编译您这个项目然后输出canal_client_1.0.22.2.zip

kobeng

请问下canal是100%不丢消息的吗

2

如果canal突然挂了，或者有段时间没运行，增量是否会丢失

yizhixiaotaozi

无法同步创建表的命令？

2

create table命令无法被同步？是不是有bug？

zmaxbin

请问canal客户端会经常出现超时，大概是什么情况？

5

``` #=====canal client==================== #=====2016==================== #=====liukelin==================== #=====conf:/root/ali_canal_client/conf/canal.properties #=====host:192.168.1.120:11111 #=====instance:example connect success! startup... java.util.concurrent.TimeoutException at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:76) at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:110) at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36) at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:366) at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:292) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:824) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:778) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:868) at canal.client.rabbitmq.push_rabbitmq(rabbitmq.java:50)...

sentball