Re: ServiceThread apache版本的一些疑问?

2018-06-11 Thread 卢松
你好,zhanhui, 我说的不同不是AtomicBoolean那块,如下: apache版本使用的是这个对象 CountDownLatch2 waitPoint = new CountDownLatch2(1); 做的wait操作。 而alibaba版本使用的object的wait操作, 这两种实现有什么区别? object.wait会导致死锁吗?或者不会从睡眠中醒来? Thanks 卢松 Zhanhui Li 于2018年6月11日周一 上午10:04写道: > > 主要是缩小了锁的粒度. pls, 原子变量比对象锁效率好一点. > > > 在 2018年6月10日,下

【ConsumeQueue刷盘错误】

2018-06-11 Thread 杨春晖
storeerror.log出现ConsumeQueue刷盘错误的日志信息,有朋友了解是什么情况吗~ 版本是4.2.0 -- Best wishes! Chunhui Yang Institute of Network Technology Beijing University of Post and Telecommunications Email: chuenf...@163.com Telephone: +86 188 1179 3568

Re: ServiceThread apache版本的一些疑问?

2018-06-11 Thread Zhanhui Li
object.wait会导致死锁吗?不会, Java Object锁本身还是偏重的操作. 没有CAS这种原子操作轻量. 或者不会从睡眠中醒来? 2018-06-11 15:28 GMT+08:00 卢松 : > 你好,zhanhui, > > 我说的不同不是AtomicBoolean那块,如下: > > apache版本使用的是这个对象 CountDownLatch2 waitPoint = new CountDownLatch2(1); > 做的wait操作。 > > 而alibaba版本使用的object的wait操作, > > 这两种实现有什么区别? > object.wait

?????? CONSUME_FROM_LAST_OFFSET issue

2018-06-11 Thread ??????
hi zhanhui, CONSUME_FROM_LAST_OFFSET?? Consumer Group??Topic topic??200??group??201 ??group. ?? -- Have a nice dayFrancis Lee QQ

Re: CONSUME_FROM_LAST_OFFSET issue

2018-06-11 Thread 卢松
关于CONSUME_FROM_LAST_OFFSET在新消费组中不起作用的问题,我有个文章详细说明了。 https://mp.weixin.qq.com/s/XjNjE_Hwg9WLPiInSuPMYw 文章中有图片。 以前碰到过一个问题,一个新消费组上线时和我们期望的消费行为有偏差,今天专门研究下这个问题,看看是怎么回事。 在RocketMQ中,假如一个新消费组订阅了几个topic,按正常人或者正常业务的期望,新消费组应该从订阅topic的最后一个消息开始消费,但是实际情形不是如此,有时候新消费组会从这些topic的开头开始消费。这就是新消费组上线的风险点。 这对业务来