[GitHub] [rocketmq] joeCarf added a comment to the discussion: Cannot invoke "org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()" because "this.timerFlushService" is null

2023-08-24 Thread via GitHub
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:

[GitHub] [rocketmq-client-python] huangwjwork opened a new issue, #142: what the max msg body size consumer supported

2023-08-24 Thread via GitHub
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] [rocketmq] n1nja88888 closed the discussion with a comment: 生产者先于消费者启动,并在消费者启动之前投递了一些消息,消费者启动后为啥不能消费那些已投递但未消费的消息?

2023-08-24 Thread via GitHub
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] [rocketmq] mz0113 closed a discussion: 求教 v5.1.0 事务消息Broker回查check()逻辑中 isNeedCheck方法到底要表达什么意思呢?

2023-08-24 Thread via GitHub
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] [rocketmq] mz0113 closed the discussion with a comment: 求教 v5.1.0 事务消息Broker回查check()逻辑中 isNeedCheck方法到底要表达什么意思呢?

2023-08-24 Thread via GitHub
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] [rocketmq] mz0113 added a comment to the discussion: 事务消息支持分支事务吗?

2023-08-24 Thread via GitHub
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