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

暂无关注.....

粉丝

暂无粉丝.....


半兽人 回复 农村外出务工男 kafka消费者客户端(0.10.0.1API) 中:
insertIntoDb是你自己的,你用下面那个单个偏移量提交的。
今天有更新了一点内容,你可以看下,明天继续更新。
3月前
农村外出务工男 kafka消费者客户端(0.10.0.1API) 发表评论:
你好,
insertIntoDb(buffer);
consumer.commitSync();这2个操作不是一个原子操作,会存在消息重复消费的情况,有解决方案的demo嘛?

3月前

半兽人 回复 农村外出务工男 kafka消费者客户端(0.10.0.1API) 评论:
insertIntoDb是你自己的,你用下面那个单个偏移量提交的。
今天有更新了一点内容,你可以看下,明天继续更新。
3月前
农村外出务工男 kafka消费者客户端(0.10.0.1API) 发表评论:
你好,
insertIntoDb(buffer);
consumer.commitSync();这2个操作不是一个原子操作,会存在消息重复消费的情况,有解决方案的demo嘛?

3月前