OrcHome OrcHome
OrcHome个人中心.
农村外出务工男 修改资料 更换头像
关注(0) 粉丝(0) 积分(0)
关注

暂无关注.....

粉丝

暂无粉丝.....


咖啡店的卡尔萨斯 回复 农村外出务工男 kafka消费者客户端(0.10.0.1API) 中:
如果insertIntoDb是幂等性的,那就啥也不用管了
1月前
咖啡店的卡尔萨斯 回复 农村外出务工男 kafka消费者客户端(0.10.0.1API) 中:
其实这个就是leastone 和mostone出现的模式。会导致消息重复。这个只能自己在业务逻辑中用redis或者其他东西处理吧
1月前
半兽人 回复 农村外出务工男 kafka消费者客户端(0.10.0.1API) 中:
insertIntoDb是你自己的,你用下面那个单个偏移量提交的。
今天有更新了一点内容,你可以看下,明天继续更新。
5月前
农村外出务工男 kafka消费者客户端(0.10.0.1API) 发表评论:
你好,
insertIntoDb(buffer);
consumer.commitSync();这2个操作不是一个原子操作,会存在消息重复消费的情况,有解决方案的demo嘛?

5月前

咖啡店的卡尔萨斯 回复 农村外出务工男 kafka消费者客户端(0.10.0.1API) 评论:
如果insertIntoDb是幂等性的,那就啥也不用管了
1月前
咖啡店的卡尔萨斯 回复 农村外出务工男 kafka消费者客户端(0.10.0.1API) 评论:
其实这个就是leastone 和mostone出现的模式。会导致消息重复。这个只能自己在业务逻辑中用redis或者其他东西处理吧
1月前
半兽人 回复 农村外出务工男 kafka消费者客户端(0.10.0.1API) 评论:
insertIntoDb是你自己的,你用下面那个单个偏移量提交的。
今天有更新了一点内容,你可以看下,明天继续更新。
5月前
农村外出务工男 kafka消费者客户端(0.10.0.1API) 发表评论:
你好,
insertIntoDb(buffer);
consumer.commitSync();这2个操作不是一个原子操作,会存在消息重复消费的情况,有解决方案的demo嘛?

5月前