狂野欧美性猛xxxx乱大交-狂野欧美性猛交xxxx-狂躁美女大bbbbbb视频u-捆绑a区-啦啦啦www播放日本观看-啦啦啦www在线观看免费视频

二維碼
企資網

掃一掃關注

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

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

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

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

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

配置

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

算法公式

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

RoundRobin輪詢策略

RoundRobinAssignor輪詢策略是將消費組內所有消費者以及消費者所訂閱的所有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ā)現,consumer0和consumer1原來消費的分區(qū)大多發(fā)生了改變。接下來我們再來看下粘性分配策略。

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

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

反饋

用戶
反饋

主站蜘蛛池模板: 国产伦精品一区二区三区免 | 麻豆精品永久免费视频 | 久久中文字幕久久久久 | 国产在线一区二区三区 | 夜夜躁日日躁狠狠 | 欧美综合影院 | 成人毛片免费网站 | 久久久久久国产精品视频 | 亚洲狠狠网站色噜噜 | 国产精品亚洲综合久久 | 欧美伦理一区二区三区 | 伊人热久久 | 夜色资源网yese321 | 色网站在线播放 | 色婷婷精品 | 久久香蕉国产线看观看99 | 精品国产成人系列 | 国产性做久久久久久 | 日本三级11k影院在线 | 国产精品福利一区二区久久 | 日韩黄色网| 草久视频在线观看 | 看久久| 一区二区日韩 | 大陆一级毛片免费视频观看i | 女人用粗大自熨喷水在线视频 | 国产玖玖视频 | 真实国产乱子伦精品免费 | 色片在线 | 美女超逼| 在线观看三级拍拍视频 | 国产精品夜色视频一区二区 | 中文字幕一区二区三区在线观看 | 国产精品免费入口视频 | 欧美在线视频网站 | 国产精品成人在线播放 | 在线欧洲成人免费视频 | 俄罗斯一级毛片免费视频 | 中文日韩字幕一区在线观看 | 久久国产精品亚洲一区二区 | 在线视频www|