GitHub user joeCarf added a comment to the discussion: Cannot invoke
"org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()"
because "this.timerFlushService" is null
hi 贴一下你的指令 我看下能否复现
GitHub link:
huangwjwork opened a new issue, #142:
URL: https://github.com/apache/rocketmq-client-python/issues/142
when I consumer some msg ,I got exception
```
terminate called after throwing an instance of
"boost::exception_detail::clone_ipml>"
what(): zlib error
```
the original
GitHub user n1nja8 closed the discussion with a comment:
生产者先于消费者启动,并在消费者启动之前投递了一些消息,消费者启动后为啥不能消费那些已投递但未消费的消息?
> 若队列 minOffset 为0,且数据还在内存中,则会从 0 开始消费
想问一下这里这样设置的目的是什么?
GitHub link:
https://github.com/apache/rocketmq/discussions/6702#discussioncomment-6811305
This is an
GitHub user mz0113 closed a discussion: 求教 v5.1.0 事务消息Broker回查check()逻辑中
isNeedCheck方法到底要表达什么意思呢?
```java
boolean isNeedCheck = opMsg == null &&
valueOfCurrentMinusBorn > checkImmunityTime
|| opMsg != null && opMsg.get(opMsg.size() -
GitHub user mz0113 closed the discussion with a comment: 求教 v5.1.0
事务消息Broker回查check()逻辑中 isNeedCheck方法到底要表达什么意思呢?
想通了,解决了
GitHub link:
https://github.com/apache/rocketmq/discussions/7244#discussioncomment-6811208
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user mz0113 added a comment to the discussion: 事务消息支持分支事务吗?
这简单啊 , 你三个消息回查时候用相同的txId回查不就好了 .
GitHub link:
https://github.com/apache/rocketmq/discussions/6835#discussioncomment-6810771
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an