
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
spring-cloud-starter-stream-rocketmq消费者不支持批量消费的解决方案
需要批量消费的消费者,使用rocketmq-spring-boot-starter的配置代替stream。基于rocketmq-springboot-starter实现消费者批量消费注意批量消费的消费者应该单独配置(如下图),不要配置在stream下面(如上图)
基于Canal监听Mysql的binlog变更同步到elasticsearch失败的问题排查
再看dbTableEsSyncConfig这个map集合,它的value存放的是你配置的yml文件,而key是采用配置的destination+数据库库名+表名,而这里这个数据库名就是你在adapter的配置文件中配置的mysql url中写的数据库名,我写的时候就是。而adapter监听到的binlog是数据库名全部转为小写后的字符串,这样就会在下面这里判断的时候configMap为null,就
到底了







