二維碼
        企資網(wǎng)

        掃一掃關(guān)注

        當前位置: 首頁 » 企資快報 » 產(chǎn)品 » 正文

        消費者分區(qū)分配策略_Stricky_Range

        放大字體  縮小字體 發(fā)布日期:2023-03-17 19:54:32    作者:葉昊天    瀏覽次數(shù):70
        導(dǎo)讀

        Range范圍分配策略是Kafka默認的分配策略,它可以確保每個消費者消費的分區(qū)數(shù)量是均衡的。注意:Rangle范圍分配策略是針對每個Topic的。配置配置消費者的partition.assignment.strategy為org.apache.kafka.clients.c

        Range范圍分配策略是Kafka默認的分配策略,它可以確保每個消費者消費的分區(qū)數(shù)量是均衡的。注意:Rangle范圍分配策略是針對每個Topic的。

        配置

        配置消費者的partition.assignment.strategy為org.apache.kafka.clients.consumer.RangeAssignor。

        算法公式

        n = 分區(qū)數(shù)量 / 消費者數(shù)量
        m = 分區(qū)數(shù)量 % 消費者數(shù)量
        前m個消費者消費n+1個
        剩余消費者消費n個

        RoundRobin輪詢策略

        RoundRobinAssignor輪詢策略是將消費組內(nèi)所有消費者以及消費者所訂閱的所有topic的partition按照字典序排序(topic和分區(qū)的hashcode進行排序),然后通過輪詢方式逐個將分區(qū)以此分配給每個消費者。

        配置

        配置消費者的partition.assignment.strategy為org.apache.kafka.clients.consumer.RoundRobinAssignor。

        Stricky粘性分配策略

        從Kafka 0.11.x開始,引入此類分配策略。主要目的:

        1. 分區(qū)分配盡可能均勻

        2. 在發(fā)生rebalance的時候,分區(qū)的分配盡可能與上一次分配保持相同
        沒有發(fā)生rebalance時,Striky粘性分配策略和RoundRobin分配策略類似。

        上面如果consumer2崩潰了,此時需要進行rebalance。如果是Range分配和輪詢分配都會重新進行分配,例如:

        通過上圖,我們發(fā)現(xiàn),consumer0和consumer1原來消費的分區(qū)大多發(fā)生了改變。接下來我們再來看下粘性分配策略。

        我們發(fā)現(xiàn),Striky粘性分配策略,保留rebalance之前的分配結(jié)果。這樣,只是將原先consumer2負責(zé)的兩個分區(qū)再均勻分配給consumer0、consumer1。這樣可以明顯減少系統(tǒng)資源的浪費,例如:之前consumer0、consumer1之前正在消費某幾個分區(qū),但由于rebalance發(fā)生,導(dǎo)致consumer0、consumer1需要重新消費之前正在處理的分區(qū),導(dǎo)致不必要的系統(tǒng)開銷。(例如:某個事務(wù)正在進行就必須要取消了)

         
        (文/葉昊天)
        免責(zé)聲明
        本文僅代表作發(fā)布者:葉昊天個人觀點,本站未對其內(nèi)容進行核實,請讀者僅做參考,如若文中涉及有違公德、觸犯法律的內(nèi)容,一經(jīng)發(fā)現(xiàn),立即刪除,需自行承擔相應(yīng)責(zé)任。涉及到版權(quán)或其他問題,請及時聯(lián)系我們刪除處理郵件:weilaitui@qq.com。
         

        Copyright ? 2016 - 2025 - 企資網(wǎng) 48903.COM All Rights Reserved 粵公網(wǎng)安備 44030702000589號

        粵ICP備16078936號

        微信

        關(guān)注
        微信

        微信二維碼

        WAP二維碼

        客服

        聯(lián)系
        客服

        聯(lián)系客服:

        在線QQ: 303377504

        客服電話: 020-82301567

        E_mail郵箱: weilaitui@qq.com

        微信公眾號: weishitui

        客服001 客服002 客服003

        工作時間:

        周一至周五: 09:00 - 18:00

        反饋

        用戶
        反饋

        大地资源中文在线观看免费版| 免费A级毛片无码A∨免费| 最近中文字幕mv免费高清在线| 精品久久久久久久无码 | 人妻无码αv中文字幕久久| 制服中文字幕一区二区| 无码人妻精品一区二区| 今天免费中文字幕视频| 黑人无码精品又粗又大又长| 无码av中文一二三区| 免费一区二区无码视频在线播放| 无码日韩人妻精品久久蜜桃 | 免费无码国产在线观国内自拍中文字幕 | 最新国产AV无码专区亚洲| 天堂亚洲国产中文在线| 国产V亚洲V天堂无码| 亚洲精品无码专区久久久| 狠狠综合久久综合中文88| 亚洲区日韩区无码区| 色AV永久无码影院AV| 日韩成人无码中文字幕| 天堂а√中文在线| 精品无码一区二区三区爱欲| 中文无码字慕在线观看| 无码毛片一区二区三区中文字幕| a中文字幕1区| 一区二区三区无码高清| 国产成人午夜无码电影在线观看 | 国产爆乳无码视频在线观看| 蜜桃臀无码内射一区二区三区| 国产在线无码精品电影网| 中文精品人人永久免费| 惠民福利中文字幕人妻无码乱精品| 亚洲日本va中文字幕久久| 中文人妻无码一区二区三区 | 一本一道精品欧美中文字幕 | 久久久久亚洲AV无码去区首| 国产av无码专区亚洲av桃花庵| 国产V亚洲V天堂A无码| 一区二区三区人妻无码| 夜夜添无码试看一区二区三区|