kafka消費有幾種模式?
kafka消費有三種模式,如下所述:
at most onece模式
基本思想是保證每一條消息commit成功之后,再進行消費處理;
設置自動提交為false,接收到消息之后,首先commit,然后再進行消費
at least onece模式
基本思想是保證每一條消息處理成功之后,再進行commit;
設置自動提交為false;消息處理成功之后,手動進行commit;
采用這種模式時,最好保證消費操作的“冪等性”,防止重復消費;
exactly onece模式
核心思想是將offset作為唯一id與消息同時處理,并且保證處理的原子性;
設置自動提交為false;消息處理成功之后再提交;
比如對于關系型數據庫來說,可以將id設置為消息處理結果的唯一索引,再次處理時,如果發現該索引已經存在,那么就不處理;
上一篇前端動態增加Field