二維碼
        企資網

        掃一掃關注

        當前位置: 首頁 » 企資快報 » 科普知識 » 正文

        消費者分區分配策略_Stricky_Range

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

        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需要重新消費之前正在處理的分區,導致不必要的系統開銷。(例如:某個事務正在進行就必須要取消了)

         
        (文/葉昊天)
        打賞
        免責聲明
        本文為葉昊天推薦作品?作者: 葉昊天。歡迎轉載,轉載請注明原文出處:http://m.sneakeraddict.net/qzkb/show-112130.html 。本文僅代表作者個人觀點,本站未對其內容進行核實,請讀者僅做參考,如若文中涉及有違公德、觸犯法律的內容,一經發現,立即刪除,作者需自行承擔相應責任。涉及到版權或其他問題,請及時聯系我們郵件:weilaitui@qq.com。
         

        Copyright ? 2016 - 2023 - 企資網 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

        反饋

        用戶
        反饋

        无码精品人妻一区| 人妻无码久久一区二区三区免费| 直接看的成人无码视频网站| 亚洲国产精品无码久久久不卡| av无码国产在线看免费网站| 午夜视频在线观看www中文| 午夜无码伦费影视在线观看| 亚洲人成无码网WWW| 亚洲中文字幕成人在线| 97免费人妻无码视频| 最近2019中文字幕免费直播 | 国产亚洲精久久久久久无码| 亚洲国产精品无码久久久久久曰| 亚洲日韩在线中文字幕综合 | 人禽无码视频在线观看| 暖暖免费日本在线中文| 精品一区二区三区无码免费视频| 久久中文字幕无码专区| 国产精品无码素人福利| 波多野结衣AV无码久久一区| 亚洲美日韩Av中文字幕无码久久久妻妇 | 无码av最新无码av专区| 婷婷综合久久中文字幕| 精品无码久久久久久久久久 | 中文字幕一区在线观看视频| 国产午夜精品无码| 久久久久av无码免费网| 亚洲一区无码中文字幕| 国产精品无码久久久久| 亚洲AV无码久久| 欧美无乱码久久久免费午夜一区二区三区中文字幕 | 中国无码人妻丰满熟妇啪啪软件| 永久免费无码日韩视频| 久热中文字幕无码视频| 日韩a级无码免费视频| 久久精品中文字幕久久| 大学生无码视频在线观看| 亚洲AV无码1区2区久久| 无码av免费毛片一区二区| 日本中文字幕电影| 亚洲 欧美 国产 日韩 中文字幕|