为了避免重复消费：
在服务器的数据库端记录一个状态，这个状态标志着这条消息被正确消费了 。如果在向kafka提交commit之前服务器崩掉了，再次启动时服务器读取这个状态，如果是这个消息被正确消费过的，就把指针指向下一条数据。
标签：状态,消费,kafka,提交,服务器,用预 From： https://www.cnblogs.com/zqlmianshi/p/17444682.html
为了避免重复消费：
在服务器的数据库端记录一个状态，这个状态标志着这条消息被正确消费了 。如果在向kafka提交commit之前服务器崩掉了，再次启动时服务器读取这个状态，如果是这个消息被正确消费过的，就把指针指向下一条数据。
标签：状态,消费,kafka,提交,服务器,用预 From： https://www.cnblogs.com/zqlmianshi/p/17444682.html