Commits

Branch selector

 c73ccbf

User selector

All users

All time

Commit History

Commits on Mar 5, 2026

• [ISSUE #6423]Implement `getConsumerConfig` admin command for querying subscription group configuration (#6708)

  WaterWhisperer

  authored
  c73ccbf

  Copy full SHA for c73ccbf

• [ISSUE #6421]Implement `statsAll` admin command for comprehensive topic and consumer group statistics (#6706)

  WaterWhisperer

  authored
  15f28b1

  Copy full SHA for 15f28b1

Commits on Mar 4, 2026

• [ISSUE #6420]Implement `queryCq` admin command for querying consume queue data and metadata (#6705)

  WaterWhisperer

  authored
  05e6b72

  Copy full SHA for 05e6b72

• [ISSUE #6703]🚀Add NamespaceRpcHook for injecting namespace metadata into RPC requests (#6704)

  mxsm

  authored
  f060270

  Copy full SHA for f060270

• [ISSUE #6701]♻️Refactor AsyncTraceDispatcher to use tokio::sync::Mutex for trace producer and implement round-robin queue selection for message sending (#6702)

  mxsm

  authored
  541539d

  Copy full SHA for 541539d

• Bump quote from 1.0.44 to 1.0.45 (#6694)

  dependabot[bot]

  authored
  1cdc170

  Copy full SHA for 1cdc170

• [ISSUE #6697]🚀Implement AsyncTraceDispatcher for asynchronous trace data handling in RocketMQ (#6698)

  mxsm

  authored
  9e53d93

  Copy full SHA for 9e53d93

• [ISSUE #6699]🚀Refactor send callback to use ArcSendCallback in send_with_selector.rs (#6700)

  mxsm

  authored
  6d886e3

  Copy full SHA for 6d886e3

• [ISSUE #6690]🧪 Add test case for TraceDispatcherType (#6693)

  Show description for 2715c99
  oopscompiled

  authored
  2715c99

  Copy full SHA for 2715c99

Commits on Mar 3, 2026

• Bump tokio from 1.49.0 to 1.50.0 (#6695)

  dependabot[bot]

  authored
  3ebb564

  Copy full SHA for 3ebb564

• [ISSUE #6691]🚀Add TraceDataEncoder for encoding and decoding trace data in RocketMQ (#6692)

  mxsm

  authored
  1609878

  Copy full SHA for 1609878

• [ISSUE #6688]🚀Add TraceDispatcherType enum to categorize trace data sources (#6689)

  mxsm

  authored
  1d167fd

  Copy full SHA for 1d167fd

• [ISSUE #6685]🚀Add TraceTransferBean struct for batched trace data transmission (#6686)

  mxsm

  authored
  3987744

  Copy full SHA for 3987744

• [ISSUE #6419]Implement `checkRocksdbCqWriteProgress` admin command for validating RocksDB consume queue consistency (#6681)

  WaterWhisperer

  authored
  8c4959f

  Copy full SHA for 8c4959f

• [ISSUE #6683]✨Add benchmarks for MessageUtil and optimize property handling in create_reply_message (#6684)

  mxsm

  authored
  b753a3d

  Copy full SHA for b753a3d

• [ISSUE #6679]🚀Implement tracing logic in ConsumeMessageTraceHook for message consumption lifecycle (#6680)

  mxsm

  authored
  934ae0a

  Copy full SHA for 934ae0a

• [ISSUE #6672]Add unit tests for CheckForbiddenContext struct (#6678)

  swaploard

  authored
  505de1e

  Copy full SHA for 505de1e

• [ISSUE #6676]refactor: change hook_name return type to &'static str (#6677)

  Show description for 38eedf6
  a638011

  authored
  38eedf6

  Copy full SHA for 38eedf6

• [ISSUE #6674]♻️Refactor consume message hooks to use immutable context and improve safety (#6675)

  mxsm

  authored
  603134f

  Copy full SHA for 603134f

• [ISSUE #6620] remove io uring integration tests (#6673)

  Show description for e2f97e7
  Tweedle2Dum

  authored
  e2f97e7

  Copy full SHA for e2f97e7

• [ISSUE #6418]Implement `producer` admin command for querying producer instances and status (#6671)

  WaterWhisperer

  authored
  72ba095

  Copy full SHA for 72ba095

• [ISSUE #6669]✨Add CheckForbiddenContext and CheckForbiddenHook traits for message validation (#6670)

  mxsm

  authored
  aea39bf

  Copy full SHA for aea39bf

• [ISSUE #6414]🚀Implement GetConsumerStatus Command for Real-Time Consumer Monitoring (#6664)

  WaterWhisperer

  authored
  360f775

  Copy full SHA for 360f775

• [ISSSUE #6569]🧪Add test case for GetLiteGroupInfoRequestHeader (#6615)

  Show description for bc6cb91
  

  slegarraga

  and

  mxsm

  authored
  bc6cb91

  Copy full SHA for bc6cb91

• [ISSUE #6667]✨Refactor expression evaluation to return structured Value types and improve error handling (#6668)

  mxsm

  authored
  551f1ee

  Copy full SHA for 551f1ee

• [ISSUE #6662]✨Enhance MessageSelector with detailed documentation and refactor for improved expression handling (#6663)

  mxsm

  authored
  9fc5e5e

  Copy full SHA for 9fc5e5e

• [ISSUE #6660]✨Add producer registration feature and enhance ProducerManager with fast channel event processing (#6661)

  mxsm

  authored
  50fdcb9

  Copy full SHA for 50fdcb9

• [ISSUE #6617]Add test case for AssignedMessageQueue (#6659)

  Edisonwei54

  authored
  81021d8

  Copy full SHA for 81021d8

• [ISSUE #6656]✨Enhance RPC hooks with improved documentation and introduce RPCHookArc for thread-safe usage (#6657)

  mxsm

  authored
  5be5c7d

  Copy full SHA for 5be5c7d

• [ISSUE #6649]enhancement: remove obsolete phase3_integration_tests.rs (#6652)2)

  Show description for d26a441
  

  Tweedle2Dum

  and

  mxsm

  authored
  d26a441

  Copy full SHA for d26a441

• [ISSUE #6638]enhancement: Update ProducerManager to use ProducerGroupName for group_channel_table mapping(#6651)

  Show description for 1e434e4
  Tweedle2Dum

  authored
  1e434e4

  Copy full SHA for 1e434e4

Commits on Mar 2, 2026

• Bump moka from 0.12.13 to 0.12.14 (#6654)

  dependabot[bot]

  authored
  c32ca17

  Copy full SHA for c32ca17

• Bump sysinfo from 0.38.2 to 0.38.3 (#6653)

  dependabot[bot]

  authored
  4c47ff1

  Copy full SHA for 4c47ff1

• [ISSUE #6629] Remove comment code from hook_utils.rs (#6650)

  BerthetLucas

  authored
  7b3d698

  Copy full SHA for 7b3d698

• [ISSUE #6413]🚀Implement CloneGroupOffset Command for Consumer Group Offset Migration (#6648)

  WaterWhisperer

  authored
  7a5f1eb

  Copy full SHA for 7a5f1eb