bookscup / canal-client Goto Github PK

https://github.com/BooksCup/canal-client/blob/master/src/main/java/com/bc/canal/client/mq/RabbitmqSender.java

Rabbitmq持久化分为3个：交换机、队列、消息

目前你只提供了队列持久化参数，导致如果使用现有交换机如果是持久化的时候，报错：
[ERROR][20190521 16:53:39,562][RabbitmqSender:86] fail to send data to rabbitmq, error: channel is already closed due to channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'durable' for exchange 'amq.fanout' in vhost '/': received 'false' but current is 'true', class-id=40, method-id=10)

另外 消息头设置不当：content_type: text/plain
应该为json

另外 https://github.com/BooksCup/canal-client/blob/master/deploy/client.sh
canal-client-1.0.0.jar 在master分支没有找到 请问小白放进去吧

另外 master和https://github.com/BooksCup/canal-client/releases 代码不同步。。

connector.subscribe(".\..");

你这一句应该添加配置文件 读取相关的值

如果这样写 会导致canal配置失效的

因为客户端一链接server 就会生效这句话

canal文档写了
检查下CanalConnector是否调用subscribe(filter)方法；有的话，filter需要和instance.properties的canal.instance.filter.regex一致，否则subscribe的filter会覆盖instance的配置，如果subscribe的filter是...，那么相当于你消费了所有的更新数据 【特别注意】