kafka消费的三种模式
- IT科技
- 关注:2.84W次
品牌型号:联想 YOGA 14c/系统版本:windows7
at most onece模式:在每一条消息commit成功之后,再进行消费处理;设置自动提交为false,接收到消息之后,首先commit,然后再进行消费。
at least onece模式:在每一条消息处理成功之后,再进行commit;设置自动提交为false;消息处理成功之后,手动进行commit。
exactly onece模式:将offset作为唯一id与消息同时处理,并且保证处理的原子性;设置自动提交为false;消息处理成功之后再提交。
- 文章版权属于文章作者所有,转载请注明 https://dongkepu.com/itkeji/8xd3pm.html