写在前面事务一致性一定要你的数据库引擎支持，我用的数据库是mysql,常见两种搜索引擎，MyISAM和InnoDb,关于它们的区别，网上很多人罗列了，我这里最重要的就是InnoDb支持事务，MyISAM不支持事务。在mysql里面，可以单独为每张表指定不同的搜索引擎，在执行下面的事务操作时，一定要确保你操作的表是支持事务的！！！（写在前面是因为，我因为一开始没有注意，所以整了两套方案，最后发现都不

我面对的场景是：需要动态的订阅新增的topic。即在程序运行的时候轮询查看kafka服务器查看是否有符合规则的新的topic，如果有的话，把它加入到订阅列表。第一种是使用spring-kafka自带注解 @KafkaListener的topicPattern参数，这里传入合适的正则表达式。然后程序本身就会去轮询（网上有代码使用，说测试的轮询时间是2min,但是我测试是5min,目前还没找到修改时间