问题：如何保证消息队列的幂等性？
这个其实考察的你对消息队列数据重复消费的问题，是否有了解，是否知道怎么解决？如果这块不知道，那么面试官会觉得如果交给你做功能，可能会出现多次消费的情况。
解决思路
为什么会出现重复消费？
比如说消费端已经消费了 offset=2，offset=3，offset=4 的三条数据，正准备把这个offset的值传给 kafka，这时候消费端机器宕机了，这个数据没传过去；
重启之后，消费端同步 kafka，kafka 那边消费的记录 offset 还是 1，那么 kafka 会认为之前的 2、3、4 都没有消费过，会把这几个数据再次传给消费端；此时消费端这边就重复对这几条数据进行了消费。在数据库里面可能就多了很多重复的数据。
像其它的MQ，也是一样，消费端再返回给 MQ 的时候，当机了或者重启了，那么都会出现重复消费的问题。
问题解决：
幂等性：一个请求，不管重复来多少次，结果是不会改变的。
每个消息都会有唯一的消息 id。
先查再保存。每次保存数据的时候，都先查一下，如果数据存在了那么就不保存。这个情况是并发不高的情况。
业务表添加约束条件。如果你的数据库将来都不会分库分表，那么可以在业务表字段加上唯一约束条件（UNIQUE），这样相同的数据就不会保存为多份。
添加消息表。在数据库里面，添加一张消息消费记录表，表字段加上唯一约束条件（UNIQUE），消费完之后就往表里插入一条数据。因为加了唯一约束条件，第二次保存的时候，mysql 就会报错，就插入不进去；通过数据库可以限制重复消费。
使用redis。如果你的系统是分布式的，又做了分库分表，那么可以使用 redis 来做记录，把消息 id 存在 redis 里，下次再有重复消息 id 在消费的时候，如果发现 redis 里面有了就不能进行消费。
高并发下。如果你的系统并发很高，那么可以使用redis或者zookeeper的分布式对消息id加锁，然后使用上面的几个方法进行幂等性控制。