<strike id="ca4is"><em id="ca4is"></em></strike>
  • <sup id="ca4is"></sup>
    • <s id="ca4is"><em id="ca4is"></em></s>
      <option id="ca4is"><cite id="ca4is"></cite></option>
    • 二維碼
      企資網

      掃一掃關注

      當前位置: 首頁 » 企資快報 » 產品 » 正文

      消費者分區分配策略_Stricky_Range

      放大字體  縮小字體 發布日期:2023-03-17 19:54:32    作者:葉昊天    瀏覽次數:71
      導讀

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

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

      配置

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

      算法公式

      n = 分區數量 / 消費者數量
      m = 分區數量 % 消費者數量
      前m個消費者消費n+1個
      剩余消費者消費n個

      RoundRobin輪詢策略

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

      配置

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

      Stricky粘性分配策略

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

      1. 分區分配盡可能均勻

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

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

      通過上圖,我們發現,consumer0和consumer1原來消費的分區大多發生了改變。接下來我們再來看下粘性分配策略。

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

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

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

      粵ICP備16078936號

      微信

      關注
      微信

      微信二維碼

      WAP二維碼

      客服

      聯系
      客服

      聯系客服:

      在線QQ: 303377504

      客服電話: 020-82301567

      E_mail郵箱: weilaitui@qq.com

      微信公眾號: weishitui

      客服001 客服002 客服003

      工作時間:

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

      反饋

      用戶
      反饋

      午夜久久久久久网站,99久久www免费,欧美日本日韩aⅴ在线视频,东京干手机福利视频
        <strike id="ca4is"><em id="ca4is"></em></strike>
      • <sup id="ca4is"></sup>
        • <s id="ca4is"><em id="ca4is"></em></s>
          <option id="ca4is"><cite id="ca4is"></cite></option>
        • 主站蜘蛛池模板: 一级做a爰片久久毛片唾| 精品综合久久久久久888蜜芽| 999影院成人在线影院| 黑白配hd视频| 男女一边做一边爽免费视频| 最近中文字幕完整视频高清10| 巨胸狂喷奶水视频www网站免费| 日本暖暖视频在线| 国内精品国产三级国产AV| 国产在线精品一区二区在线看| 亚洲色偷偷av男人的天堂| 久久久亚洲欧洲日产国码二区| 99re这里有免费视频精品| 蜜桃av无码免费看永久| 欧美高清在线精品一区| 手机看片福利久久| 国产男女免费完整视频| 免费大片黄手机在线观看| 久久亚洲精品中文字幕三区| 51国产偷自视频区视频| 精品人人妻人人澡人人爽人人| 日韩在线永久免费播放| 国产美女自慰在线观看| 免费观看午夜在线欧差毛片| 久久久999久久久精品| 黄网站色在线视频免费观看| 浪荡女天天不停挨cao日常视频| 把水管开水放b里是什么感觉| 国产91无套剧情在线播放| 亚洲va成无码人在线观看天堂| aaaa欧美高清免费| 精品国产自在现线看| 无码人妻aⅴ一区二区三区| 国产破外女出血视频| 亚洲欧美日韩自偷自拍| 一区二区三区高清在线| 苏玥马强百文择| 日本边添边摸边做边爱边| 国产挤奶水主播在线播放| 亚洲国产一成人久久精品| 91久久国产精品|