schopenhauerz
schopenhauerz
为什么这么多人做前端呢？来一起搞后端啊。
补充，你是男是女？摸不着头脑 (: )
wouldn't the garbage collector take care of this? em， i use smart_open in High concurrency and high throughput distributed system. wait the garbage collector(python's) to deal it is not good...
@flylee85 你说的是MqPushService.java吧。 其实不是严格的时间轮实现，而是根据当前的seekTimestamp去逐个seek。 ``` // 迭代出当前 seekTimestamp 下所有数据 int count = 0; try (RocksIterator it = RDB.newIterator(CFManager.CFH_DEFAULT)) { // more code } ```
有人知道限制多长时间呢？永久封禁？
我遇到过，不过我是5.0版本。 我理解是第一条消息发送时由于topic没有创建，所以第一条消息去触发了topic的创建（其实是consume queue的初始化）然后由于topic还没有创建（在消息被broker接收到时）所以消息发送失败了（write consume queue fail），所以在这里应该加一个重试，我原本打算debug一下这块的细节，不过还没来得及做。 不过丢失了第一条消息确实是一个已知的问题。
收到，感谢提问。我正在本地复现，并且正在尝试基于5.0版本修复这个问题。按照以上大家的描述我理解是一个共性问题，所以等我PR，不过由于工作的原因，可能需要点时间，烦请暂时克服一下，我尽量加快修复速度。:-）
@Jason918 CR,please.