kafka偏移量保存到mysql里_用java代码手动控制kafkaconsumer偏移量
为应对消费结果需要存储到关系数据库中,避免数据库down时consumer继续消费的场景查了很多源码都记录下来,省的下次还要过滤源码。If the results of the consumption are being stored in a relational database, storing the offset in the database as well can allow com...