logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

spring-cloud-starter-stream-rocketmq消费者不支持批量消费的解决方案

需要批量消费的消费者,使用rocketmq-spring-boot-starter的配置代替stream。基于rocketmq-springboot-starter实现消费者批量消费注意批量消费的消费者应该单独配置(如下图),不要配置在stream下面(如上图)

#java-rocketmq#rocketmq#java +1
基于Canal监听Mysql的binlog变更同步到elasticsearch失败的问题排查

再看dbTableEsSyncConfig这个map集合,它的value存放的是你配置的yml文件,而key是采用配置的destination+数据库库名+表名,而这里这个数据库名就是你在adapter的配置文件中配置的mysql url中写的数据库名,我写的时候就是。而adapter监听到的binlog是数据库名全部转为小写后的字符串,这样就会在下面这里判断的时候configMap为null,就

#mysql#elasticsearch#数据库 +2
到底了