commits  

Messages by Thread

• [I] debezium-mysql connector无法连接nameserver [rocketmq-connect] via GitHub
  • Re: [I] debezium-mysql connector无法连接nameserver [rocketmq-connect] via GitHub
  • Re: [I] debezium-mysql connector无法连接nameserver [rocketmq-connect] via GitHub
• [I] delay message time limits [rocketmq-client-go] via GitHub
  • Re: [I] delay message time limits [rocketmq-client-go] via GitHub
  • Re: [I] delay message time limits [rocketmq-client-go] via GitHub
• [I] [Bug] The tool command 'resetOffsetByTime' can't make any effect in rocketmq 5.x [rocketmq] via GitHub
  • Re: [I] [Bug] The tool command 'resetOffsetByTime' can't make any effect in rocketmq 5.x [rocketmq] via GitHub
• (rocketmq) branch develop updated: reduce duplicate calls (#9037) jinrongtong
• (rocketmq-dashboard) branch dependabot/npm_and_yarn/frontend/multi-6bc014718a created (now 31f050d) github-bot
• [PR] Bump path-to-regexp and express in /frontend [rocketmq-dashboard] via GitHub
• [PR] rocketMQ init after dubbo [rocketmq-spring] via GitHub
• [PR] reduce duplicate calls [rocketmq] via GitHub
  • Re: [PR] reduce duplicate calls [rocketmq] via GitHub
  • [PR] reduce duplicate calls [rocketmq] via GitHub
  • Re: [PR] reduce duplicate calls [rocketmq] via GitHub
• [I] [Enhancement] Enhancement title [rocketmq] via GitHub
  • Re: [I] [Enhancement] When there are too many consumers and there are too many RocketMQ client threads [rocketmq] via GitHub
  • Re: [I] [Enhancement] When there are too many consumers and there are too many RocketMQ client threads [rocketmq] via GitHub
  • Re: [I] [Enhancement] When there are too many consumers and there are too many RocketMQ client threads [rocketmq] via GitHub
  • Re: [I] [Enhancement] When there are too many consumers and there are too many RocketMQ client threads [rocketmq] via GitHub
  • Re: [I] [Enhancement] When there are too many consumers and there are too many RocketMQ client threads [rocketmq] via GitHub
  • Re: [I] [Enhancement] When there are too many consumers and there are too many RocketMQ client threads [rocketmq] via GitHub
• (rocketmq) branch develop updated: refactor(LmqBrokerStatsManager): extract common method to eliminate duplicate logic (#9034) lizhanhui
• [PR] refactor(LmqBrokerStatsManager): Refactor Redundant Code in LmqBrokerStatsManager [rocketmq] via GitHub
  • Re: [PR] refactor(LmqBrokerStatsManager): Refactor Redundant Code in LmqBrokerStatsManager [rocketmq] via GitHub
  • Re: [PR] refactor(LmqBrokerStatsManager): Refactor Redundant Code in LmqBrokerStatsManager [rocketmq] via GitHub
• [I] [Enhancement] Refactor Redundant Code in LmqBrokerStatsManager to Improve Maintainability and Readability [rocketmq] via GitHub
  • Re: [I] [Enhancement] Refactor Redundant Code in LmqBrokerStatsManager to Improve Maintainability and Readability [rocketmq] via GitHub
• [I] 初始化Producer时需要设置通信配置以及预绑定的Topic报错 [rocketmq] via GitHub
  • Re: [I] 初始化Producer时需要设置通信配置以及预绑定的Topic报错 [rocketmq] via GitHub
  • Re: [I] 初始化Producer时需要设置通信配置以及预绑定的Topic报错 [rocketmq] via GitHub
  • Re: [I] 初始化Producer时需要设置通信配置以及预绑定的Topic报错 [rocketmq] via GitHub
  • Re: [I] 初始化Producer时需要设置通信配置以及预绑定的Topic报错 [rocketmq] via GitHub
• [I] [Bug] Restart broker failed while load index files. [rocketmq] via GitHub
• Re: [I] 可以正常接收到阿里云4.x rocketmq 发送得消息 但是阿里云后台不显示已经被消费 [rocketmq-spring] via GitHub
• Re: [I] [Bug] Pop retry topics not cleaned up after deleting pop subscription [rocketmq] via GitHub
  • Re: [I] [Bug] Pop retry topics not cleaned up after deleting pop subscription [rocketmq] via GitHub
  • Re: [I] [Bug] Pop retry topics not cleaned up after deleting pop subscription [rocketmq] via GitHub
• (rocketmq) branch develop updated: [ISSUE #8979] Add configurable switch for timer message retry logic (#8980) jinrongtong
• Re: [I] lockAll函数没有正常续约LastLockTime导致consumeMessageOrderly函数报错the message queue lock expired, so consume later [rocketmq-client-go] via GitHub
• Re: [I] 请教，在client端设置消息的key-value怎么没在rocketmq-console上体现呀？ [rocketmq-client-go] via GitHub
• Re: [I] 什么原因会导致客户端小概率停止消费某个queue的消息？ [rocketmq-client-go] via GitHub
• Re: [I] 此项目若干不兼容的升级导致项目无法编译 [rocketmq-client-go] via GitHub
• Re: [I] [BUG] 使用 pushconsumer 客户端，默认重试两次后就commit，消息状态变成consumed [rocketmq-client-go] via GitHub
• Re: [I] 如何发送定时消息？ [rocketmq-client-go] via GitHub
• Re: [I] update offset to broker success这个日志输出太多 [rocketmq-client-go] via GitHub
• Re: [I] 请教，消费方式用法 [rocketmq-client-go] via GitHub
• [I] [Enhancement] Make some SYSTEM_ERROR error more meaningful [rocketmq] via GitHub
  • Re: [I] [Enhancement] Make some SYSTEM_ERROR error more meaningful [rocketmq] via GitHub
• [PR] Adjust some error code for SYSTEM_ERROR [rocketmq] via GitHub
  • Re: [PR] Adjust some error code for SYSTEM_ERROR [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9028]Adjust some error code for SYSTEM_ERROR [rocketmq] via GitHub
• [PR] [ISSUE #878] The java implementation of recalling API [rocketmq-clients] via GitHub
  • Re: [PR] [ISSUE #878] The java implementation of recalling API [rocketmq-clients] via GitHub
• [PR] createFlushConsumeQueueService for loadAndStartConsumerServiceOnly [rocketmq] via GitHub
  • Re: [PR] CreateFlushConsumeQueueService for loadAndStartConsumerServiceOnly [rocketmq] via GitHub
  • [PR] CreateFlushConsumeQueueService for loadAndStartConsumerServiceOnly [rocketmq] via GitHub
• [I] [Feature] Implement Recalling API in Java SDK [rocketmq-clients] via GitHub
  • Re: [I] [Feature] Implement Recalling API in Java SDK [rocketmq-clients] via GitHub
• (rocketmq) branch develop updated: [ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of message body (#9016) lizhimin
• [I] [Feature] [RIP‐69] Pop Consumption Improvement Based on RocksDB [rocketmq] via GitHub
  • Re: [I] [Feature] [RIP‐73] Pop Consumption Improvement Based on RocksDB [rocketmq] via GitHub
• [I] [Bug] 4.9.3版本 出现sendKernelImpl call timeout 这个报错 [rocketmq] via GitHub
  • Re: [I] [Bug] 4.9.3版本 出现sendKernelImpl call timeout 这个报错 [rocketmq] via GitHub
  • Re: [I] [Bug] 4.9.3版本 出现sendKernelImpl call timeout 这个报错 [rocketmq] via GitHub
• [I] [Bug] RocketMQ Message hasn't been sent. Caused by The producer service state not OK, CREATE_JUST [rocketmq] via GitHub
  • Re: [I] [Bug] RocketMQ Message hasn't been sent. Caused by The producer service state not OK, CREATE_JUST [rocketmq] via GitHub
• Re: [I] [Bug] Condition returned by method "testStateAndRecover" in class org.apache.rocketmq.store.timer.TimerMessageStoreTest was not fulfilled within 5 seconds. [rocketmq] via GitHub
  • Re: [I] [Bug] Condition returned by method "testStateAndRecover" in class org.apache.rocketmq.store.timer.TimerMessageStoreTest was not fulfilled within 5 seconds. [rocketmq] via GitHub
  • Re: [I] [Bug] Condition returned by method "testStateAndRecover" in class org.apache.rocketmq.store.timer.TimerMessageStoreTest was not fulfilled within 5 seconds. [rocketmq] via GitHub
• [PR] [ISSUE #9021] Correct the error message of acl command [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9021] Correct the error message of acl command [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9021] Correct the error message of acl command [rocketmq] via GitHub
• [I] [Enhancement] Correct the error message of acl command [rocketmq] via GitHub
  • Re: [I] [Enhancement] Correct the error message of acl command [rocketmq] via GitHub
• Re: [PR] [ISSUE #7480] Fix the offset in the timerCheckPoint will not be corrected when the commitlog and consumeQueue are truncated [rocketmq] via GitHub
• (rocketmq) branch develop updated: [ISSUE #7480] Fix the offset in the timerCheckPoint will not be corrected when the commitlog and consumeQueue are truncated (#7488) jinrongtong
• [PR] [ISSUE #9019]feat: make check expired message interval configurable to reduce the consuming thread block time [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9019] feat: make check expired message interval configurable to reduce the consuming thread block time [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9019] feat: make check expired message interval configurable to reduce the consuming thread block time [rocketmq] via GitHub
• [I] [Feature] Make check expired message interval configurable to reduce the consuming thread block time [rocketmq] via GitHub
  • Re: [I] [Feature] Make check expired message interval configurable to reduce the consuming thread block time [rocketmq] via GitHub
  • Re: [I] [Feature] Make check expired message interval configurable to reduce the consuming thread block time [rocketmq] via GitHub
  • Re: [I] [Feature] Make check expired message interval configurable to reduce the consuming thread block time [rocketmq] via GitHub
• [PR] [ISSUE #485]fix: send failed show exception details [rocketmq-client-cpp] via GitHub
  • Re: [PR] [ISSUE #485]fix: send failed show exception details [rocketmq-client-cpp] via GitHub
• [I] [Feature] Show more exception detail when send messages failed. [rocketmq-client-cpp] via GitHub
• [PR] [ISSUE #483]feat: add get message store/born host c interface [rocketmq-client-cpp] via GitHub
  • Re: [PR] [ISSUE #483]feat: add get message store/born host c interface [rocketmq-client-cpp] via GitHub
• [I] [Feature] Add c interfaces to get message's store host. [rocketmq-client-cpp] via GitHub
• [PR] [ISSUE #481]Fixed the issue that reset location cannot be consumed immediately [rocketmq-client-cpp] via GitHub
  • Re: [PR] [ISSUE #481]Fixed the issue that reset location cannot be consumed immediately [rocketmq-client-cpp] via GitHub
• [I] [Bug] Reset consume offset then the consumer cannot continue consume immediately [rocketmq-client-cpp] via GitHub
• [PR] [ISSUE #479]fix: duplicate pulls due to concurrency issues in rebalance. [rocketmq-client-cpp] via GitHub
  • Re: [PR] [ISSUE #479]fix: duplicate pulls due to concurrency issues in rebalance. [rocketmq-client-cpp] via GitHub
  • Re: [PR] [ISSUE #479]fix: duplicate pulls due to concurrency issues in rebalance. [rocketmq-client-cpp] via GitHub
• [I] [Bug] PushConsumer may cause consumption duplication in some scenarios due to concurrency issues. [rocketmq-client-cpp] via GitHub
• [I] [BUG] PushConsumer abnormally marked pullRT as consumeRT. [rocketmq-client-cpp] via GitHub
• [PR] [ISSUE #477] fix: metrics pull rt was reported as consume rt [rocketmq-client-cpp] via GitHub
  • Re: [PR] [ISSUE #477] fix: metrics pull rt was reported as consume rt [rocketmq-client-cpp] via GitHub
  • Re: [PR] [ISSUE #477] fix: metrics pull rt was reported as consume rt [rocketmq-client-cpp] via GitHub
• Re: [I] [Bug] Consumer still consume new message but the offset of two queues always keep the old value [rocketmq] via GitHub
  • Re: [I] [Bug] Consumer still consume new message but the offset of two queues always keep the old value [rocketmq] via GitHub
  • Re: [I] [Bug] Consumer still consume new message but the offset of two queues always keep the old value [rocketmq] via GitHub
• [I] 当 `onMessage` 要转换的消息类型为 `byte[]` 时，报错：ClassCastException: java.lang.String cannot be cast to [B [rocketmq-spring] via GitHub
• [PR] [ISSUE #876] Add transaction message retry attempt for C# client Producer [rocketmq-clients] via GitHub
• [I] [Enhancement] Add transaction message retry attempt for C# client Producer [rocketmq-clients] via GitHub
  • Re: [I] [Enhancement] Add transaction message retry attempt for C# client Producer [rocketmq-clients] via GitHub
  • Re: [I] [Enhancement] Add transaction message retry attempt for C# client Producer [rocketmq-clients] via GitHub
  • Re: [I] [Enhancement] Add transaction message retry attempt for C# client Producer [rocketmq-clients] via GitHub
• [I] void org.apache.rocketmq.client.consumer.DefaultMQPushConsumer.setNamespaceV2(java.lang.String) [rocketmq-spring] via GitHub
• Re: [I] [Bug] No topic route info in name server for the topic [rocketmq] via GitHub
• Re: [PR] [ISSUE #8380]fix wrong election in controllerMode [rocketmq] via GitHub
• (rocketmq) branch develop updated: [ISSUE #9014] Fix clusterAclConfigVersion command execution failed (#9017) dongyuanpan
• [GH] (rocketmq-spring): Workflow run "maven in /rocketmq-spring-boot-parent for org.springframework:spring-context - Update #926352864" failed! GitBox
• [PR] Bump org.springframework:spring-core from 5.3.27 to 6.1.14 [rocketmq] via GitHub
• (rocketmq) branch dependabot/maven/org.springframework-spring-core-6.1.14 created (now 99960eab26) github-bot
• [PR] Bump org.springframework:spring-core from 5.3.27 to 6.1.14 in /rocketmq-spring-boot-parent [rocketmq-spring] via GitHub
  • Re: [PR] Bump org.springframework:spring-core from 5.3.27 to 6.1.14 in /rocketmq-spring-boot-parent [rocketmq-spring] via GitHub
  • Re: [PR] Bump org.springframework:spring-core from 5.3.27 to 6.1.14 in /rocketmq-spring-boot-parent [rocketmq-spring] via GitHub
• [PR] [ISSUE #9014] Fix clusterAclConfigVersion command execution failed [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9014] Fix clusterAclConfigVersion command execution failed [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9014] Fix clusterAclConfigVersion command execution failed [rocketmq] via GitHub
• [PR] [ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of message body [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of message body [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of message body [rocketmq] via GitHub
• [I] [Bug] Omit message body causes NPE [rocketmq] via GitHub
  • Re: [I] [Bug] Omit message body causes NPE [rocketmq] via GitHub
• [I] [Bug] clusterAclConfigVersion command execution failed [rocketmq] via GitHub
  • Re: [I] [Bug] clusterAclConfigVersion command execution failed [rocketmq] via GitHub
• (rocketmq) branch develop updated: [ISSUE #9007] Fix client connection local ip is null in RemotingClient (#9008) lizhimin
• Re: [PR] [ISSUE #9007] Fix client connection local ip is null in RemotingClient [rocketmq] via GitHub
• (rocketmq-client-go) branch master updated: [ISSUE #1178] feat:pull consumer support Assign subscription type dinglei
• Re: [I] 超时时间和超时次数 [rocketmq] via GitHub
  • Re: [I] 超时时间和超时次数 [rocketmq] via GitHub
• Re: [I] [Doc] Update the pull consumer content in the doc [rocketmq] via GitHub
  • Re: [I] [Doc] Update the pull consumer content in the doc [rocketmq] via GitHub
  • Re: [I] [Doc] Update the pull consumer content in the doc [rocketmq] via GitHub
• (rocketmq) branch develop updated: fix: multiple patches during long running tests for LMQ over RocksDB (#8915) jinrongtong
• (rocketmq) branch develop updated: [ISSUE #8966] Feat: add remote address information to acl perm error jinrongtong
• (rocketmq) branch develop updated: [ISSUE #8950] Remove Redundant nullcheck of configPath (#8951) jinrongtong
• (rocketmq) branch develop updated: [ISSUE #8984] Fix the broker switch enableMixedMessageType doesn't work jinrongtong
• Re: [I] [Bug] dledger集群消息丢失 [rocketmq] via GitHub
  • Re: [I] [Bug] dledger集群消息丢失 [rocketmq] via GitHub
  • Re: [I] [Bug] dledger集群消息丢失 [rocketmq] via GitHub
• Re: [PR] using Maps.newHashMapWithExpectedSize method [rocketmq] via GitHub
  • Re: [PR] using Maps.newHashMapWithExpectedSize method [rocketmq] via GitHub
• [PR] [ISSUE #9012]Optimize RemotingTimeoutException message to print [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9012]Optimize RemotingTimeoutException message to print [rocketmq] via GitHub
• [I] [Enhancement] Optimize RemotingTimeoutException message to print [rocketmq] via GitHub
• Re: [PR] [ISSUE 4622] Improve execution efficiency of integration tests, chang… [rocketmq] via GitHub
  • Re: [PR] [ISSUE 4622] Improve execution efficiency of integration tests, chang… [rocketmq] via GitHub
  • Re: [PR] [ISSUE 4622] Improve execution efficiency of integration tests, chang… [rocketmq] via GitHub
• Re: [I] [Bug] when I delete unused topic, topic consume queue on the standby node is not deleted synchronously. [rocketmq] via GitHub
  • Re: [I] [Bug] when I delete unused topic, topic consume queue on the standby node is not deleted synchronously. [rocketmq] via GitHub
  • Re: [I] [Bug] when I delete unused topic, topic consume queue on the standby node is not deleted synchronously. [rocketmq] via GitHub
• Re: [PR] fix fail test [rocketmq] via GitHub
• Re: [PR] [ISSUE #8254]Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values [rocketmq] via GitHub
• (rocketmq) branch develop updated: test (#9010) lollipop
• Re: [PR] [ISSUE #9007] client Connection ip is null [rocketmq] via GitHub
• [PR] [ISSUE #9009] Optimize message accumulation display and Metrics in DefaultPullConsumer [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9009] Optimize message accumulation display and Metrics in DefaultPullConsumer [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9009] Optimize message accumulation display and Metrics in DefaultPullConsumer [rocketmq] via GitHub
• [I] [Enhancement] Optimize message accumulation display and Metrics. [rocketmq] via GitHub
  • Re: [I] [Enhancement] Optimize message accumulation display and Metrics. [rocketmq] via GitHub
• [I] [Bug] Client Connection ip is null [rocketmq] via GitHub
• [I] [Bug] Delayed messages that exceed the default storage expiration time cannot be uploaded to tiered storage [rocketmq] via GitHub
  • Re: [I] [Bug] Delayed messages that exceed the default storage expiration time cannot be uploaded to tiered storage [rocketmq] via GitHub
• [PR] [ISSUE #1178] feat:pull consumer support Assign subscription type [rocketmq-client-go] via GitHub
  • Re: [PR] [ISSUE #1178] feat:pull consumer support Assign subscription type [rocketmq-client-go] via GitHub
• [I] 实际效果和官方文档不对应 [rocketmq] via GitHub
  • Re: [I] 实际效果和官方文档不对应 [rocketmq] via GitHub
  • Re: [I] 负载均衡的实际效果和官方文档不对应 [rocketmq] via GitHub
  • Re: [I] 负载均衡的实际效果和官方文档不对应 [rocketmq] via GitHub
  • Re: [I] 负载均衡的实际效果和官方文档不对应 [rocketmq] via GitHub
  • Re: [I] 负载均衡的实际效果和官方文档不对应 [rocketmq] via GitHub
• [PR] [ISSUE #9002]when bytebuffer is not enough, do not throw exception [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9002]when bytebuffer is not enough, do not throw exception [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9002]when bytebuffer is not enough, do not throw exception [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9002]when bytebuffer is not enough, do not throw exception [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9002]when bytebuffer is not enough, do not throw exception [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9002]when bytebuffer is not enough, do not throw exception [rocketmq] via GitHub
  • Re: [PR] [ISSUE #9002]when bytebuffer is not enough, do not throw exception [rocketmq] via GitHub
• [I] [Bug] In the master-slave replication scenario, since the replication is based on bytes, the slave data will often be temporarily incomplete. [rocketmq] via GitHub
  • Re: [I] [Bug] In the master-slave replication scenario, since the replication is based on bytes, the slave data will often be temporarily incomplete. [rocketmq] via GitHub
• Re: [I] Use lamdba function to prevent modification to topicConfigTable; [rocketmq] via GitHub
  • Re: [I] Use lamdba function to prevent modification to topicConfigTable; [rocketmq] via GitHub
  • Re: [I] Use lamdba function to prevent modification to topicConfigTable; [rocketmq] via GitHub
• Re: [I] [Bug] The interface definition of queryMessage is not clear, and the query result may exceed the maxNum passed. [rocketmq] via GitHub
  • Re: [I] [Bug] The interface definition of queryMessage is not clear, and the query result may exceed the maxNum passed. [rocketmq] via GitHub
  • Re: [I] [Bug] The interface definition of queryMessage is not clear, and the query result may exceed the maxNum passed. [rocketmq] via GitHub
• Re: [I] at org.apache.rocketmq.proxy.grpc.v2.channel.GrpcClientChannel.processGetConsumerRunningInfo(GrpcClientChannel.java:213) [rocketmq] via GitHub
• (rocketmq) branch develop updated: [ISSUE #7199] grpcClientChannel header add null judgement (#7238) oliverwqcwrw
• [PR] [ISSUE #8998]fix: no retry is required when time=0 [rocketmq] via GitHub
  • Re: [PR] [ISSUE #8998] no retry is required when time=0 [rocketmq] via GitHub
  • Re: [PR] [ISSUE #8998] No retry is required when the remaining time reaches zero [rocketmq] via GitHub
• [I] [Enhancement] no retry is required when time=0 [rocketmq] via GitHub
  • Re: [I] [Enhancement] no retry is required when time=0 [rocketmq] via GitHub
• [I] [Bug] 一次请求打到坏的broker把超时时间耗光，后两次打到正常的broker也因过期时间为0，无法成功 [rocketmq] via GitHub

• Earlier messages
• Later messages