liukelin
liukelin
明白了: { "query": { "match": { "content": "应用程序层是一个附加层" } }, "highlight": { "pre_tags": [ "", "" ], "post_tags": [ "", "" ], "fields": { "content": { "fragment_size": 0 } }...
您好，你的意思是为了 实现可靠消费吧。 类似于rabbitmq的 Unacked
参考MySQL从库机制，它会记录同步点(就是记录当前同步到binlog哪个文件哪一行位置)挂了再重启的话 会从这个位置继续同步。
connection rabbitmq error! connect error! 查查你 rabbitmq 是否有连接问题
这个。。是我之前写法有问题，没复用连接造成的。 后面打包会改
rabbitmq.java
connection 全局创建就行
您好，看报错是连接 canal server 错误了。 看看canal server 是否监听的是 11111 端口。
client 端没必要启动2个的。