kafka consumer频繁reblance
2016-04-21 17:45
316 查看
转载请注明地址http://www.cnblogs.com/dongxiao-yang/p/5417956.html
结论与下文相同,kafka不同topic的consumer如果用的groupid名字一样的情况下,其中任意一个topic的consumer重新上下线都会造成剩余所有的consumer产生reblance行为
,即使大家不是同一个topic,这主要是由于kafka官方支持一个consumer同时消费多个topic的情况,所以在zk上一个consumer出问题后zk是直接把group下面所有的consumer都通知一遍,这个与以前观念里认为group从属于某一个topic的概念完全不同,非常坑。
https://olnrao.wordpress.com/2015/05/15/apache-kafka-case-of-mysterious-rebalances/
结论与下文相同,kafka不同topic的consumer如果用的groupid名字一样的情况下,其中任意一个topic的consumer重新上下线都会造成剩余所有的consumer产生reblance行为
,即使大家不是同一个topic,这主要是由于kafka官方支持一个consumer同时消费多个topic的情况,所以在zk上一个consumer出问题后zk是直接把group下面所有的consumer都通知一遍,这个与以前观念里认为group从属于某一个topic的概念完全不同,非常坑。
https://olnrao.wordpress.com/2015/05/15/apache-kafka-case-of-mysterious-rebalances/
相关文章推荐
- 填充
- python编程关键字
- GCD多线程
- 十一、访问者模式(行为型模式)
- Android4.4 系统移植问题备忘
- start.S解析1
- http的get和post请求
- OpenCV坐标体系+minMaxLoc的使用细节
- SourceTree里GitFlow的使用
- 唱衰平板何以成风?坚守品质乃长胜之道
- 多位数乘一位数
- 两位数乘一位数
- dialog强退
- uva 10816 Travel in Desert(简单的好题~两种方法)
- 读《CSS.Secrets》,记录下——box-shadow,outline
- vb中的乘法运算
- 求大神指教
- Java小程序之计算三角形/圆形/矩形的周长和面积
- Struts2动态调用方法报错
- Unity3d 中 UI 开发的 MVC 模式