欧美一区二区三区,国内熟女精品熟女A片视频小说,日本av网,小鲜肉男男GAY做受XXX网站

kafka消費有幾種模式

錢衛國2年前18瀏覽0評論

kafka消費有幾種模式?

kafka消費有三種模式,如下所述:

at most onece模式

基本思想是保證每一條消息commit成功之后,再進行消費處理;

設置自動提交為false,接收到消息之后,首先commit,然后再進行消費

at least onece模式

基本思想是保證每一條消息處理成功之后,再進行commit;

設置自動提交為false;消息處理成功之后,手動進行commit;

采用這種模式時,最好保證消費操作的“冪等性”,防止重復消費;

exactly onece模式

核心思想是將offset作為唯一id與消息同時處理,并且保證處理的原子性;

設置自動提交為false;消息處理成功之后再提交;

比如對于關系型數據庫來說,可以將id設置為消息處理結果的唯一索引,再次處理時,如果發現該索引已經存在,那么就不處理;

java連kafka,kafka消費有幾種模式