mxsm/rocketmq-rust

Issues

• [Enhancement⚡️] Optimize DefaultMQPushConsumer

  #1037 opened 2 months ago by mxsm
  0

• [Feature🚀] Support order message consume for client

  #1029 opened 2 months ago by mxsm
  0

• [Bug🐛] Fix clippy check error

  #1035 opened 2 months ago by mxsm
  0

• [Feature🚀] Add order message produce example

  #1030 opened 2 months ago by mxsm
  0

• [Feature🚀] Support mq client instance clean offline broker

  #1021 opened 2 months ago by mxsm
  0

• [Enhancement⚡️] Add Default trait for RocketMQTokioRwLock and RocketMQTokioMutex

  #1022 opened 2 months ago by mxsm
  0

• [Bug🐛] Message queue changed sendHeartbeatToAllBrokerWithLockV2 faild

  #1019 opened 2 months ago by mxsm
  0

• [Feature🚀] Support client Broadcasting consume

  #1009 opened 2 months ago by mxsm
  0

• [Doc📝]Update README.md

  #1016 opened 2 months ago by mxsm
  0

• [Feature🚀] Support client Broadcasting consume-local file store

  #1012 opened 2 months ago by mxsm
  0

• [Doc📝] Update README.md

  #1014 opened 2 months ago by mxsm
  0

• [Enhancement⚡️] Remove useless clippy annotations

  #1011 opened 2 months ago by mxsm
  0

• [Enhancement⚡️] optimize and improve consume logic

  #1004 opened 2 months ago by mxsm
  0

• [Enhancement⚡️] Fix code style

  #1006 opened 2 months ago by mxsm
  0

• [Feature🚀] Add RocketMQTokioRwLock and RocketMQTokioMutex for rocketmq crate

  #1000 opened 2 months ago by mxsm
  0

• [Bug🐛] Fix clippy check error on ConfigManager

  #1002 opened 2 months ago by mxsm
  0

• [Doc📝] Add doc for MQConsumerInner

  #998 opened 2 months ago by mxsm
  0

• [Doc📝] Add doc for ConsumeFromWhere item

  #996 opened 2 months ago by mxsm
  0

• [Enhancement⚡️] Optimize RocketmqDefaultClient code

  #994 opened 2 months ago by mxsm
  0

• [Feature🚀] Support NOTIFY_CONSUMER_IDS_CHANGED(request code 40) for client

  #990 opened 2 months ago by mxsm
  0

• [Bug🐛] Fix rebalance_by_topic method bug in RebalanceImpl

  #988 opened 2 months ago by mxsm
  0

• [Feature🚀] 存储层参考automq的实现

  #973 opened 2 months ago by leyou240
  1

• [Enhancement⚡️] Add Runtime for ConsumeMessageConcurrentlyService

  #986 opened 2 months ago by mxsm
  0

• [Feature🚀] Optimize error handle

  #948 opened 2 months ago by mxsm
  0

• [Enhancement⚡️] Optimize client clusting consume

  #981 opened 2 months ago by mxsm
  0

• [Enhancement⚡️] Optimize ConnectionHandler logic

  #983 opened 2 months ago by mxsm
  0

• [Feature🚀] Supports client clusting consume

  #972 opened 2 months ago by mxsm
  0

• [Feature🚀] Support client consumer message-4

  #967 opened 2 months ago by mxsm
  0

• [Feature🚀] Support AdminBrokerProcessor get_all_consumer_offset

  #969 opened 2 months ago by 847850277
  0

• [Feature🚀] Support client consumer message-3

  #966 opened 3 months ago by mxsm
  0

• [Feature🚀] Support client consumer message-2

  #964 opened 3 months ago by mxsm
  0

• [Feature🚀] Support client consumer message-1

  #960 opened 3 months ago by mxsm
  0

• [Feature🚀] Support AdminBrokerProcessor get_consume_stats

  #953 opened 3 months ago by 847850277
  0

• [Feature🚀] Support RequestCode GET_MAX_OFFSET/GET_MIN_OFFSET(30/31) in AdminBrokerProcessor

  #950 opened 3 months ago by mxsm
  0

• [Feature🚀] Implement broker rpc message ReplyMessageProcessor

  #947 opened 3 months ago by mxsm
  0

• [Enhancement⚡️] Optimize request_callback_producer code style

  #945 opened 3 months ago by yulanggongwu
  0

• [Doc📝] Update client README.md

  #943 opened 3 months ago by note-art
  0

• [doc] Update client README.md

  #941 opened 3 months ago by mxsm
  0

• [Feature🚀] Add request callback proudcer example

  #939 opened 3 months ago by mxsm
  0

• [Feature🚀] Support producer send rpc message-3

  #934 opened 3 months ago by mxsm
  0

• [Feature🚀] Support producer send rpc message-2

  #924 opened 3 months ago by mxsm
  0

• [Enhancement⚡️]Remoting connection implements read-write separation

  #926 opened 3 months ago by mxsm
  0

• [Doc📝] Update README.md

  #927 opened 3 months ago by mxsm
  0

• [Feature🚀] Support producer send rpc message-1

  #916 opened 3 months ago by mxsm
  0

• [Feature🚀] Support AdminBrokerProcessor get_consumer_connection_list

  #909 opened 3 months ago by 847850277
  0

• [Doc📝] Update README.md

  #918 opened 3 months ago by mxsm
  0

• [Feature🚀] Implement mq producer other methods-2

  #910 opened 3 months ago by mxsm
  0

• [Feature🚀] Implement mq producer other methods-1

  #908 opened 3 months ago by mxsm
  0

• [Feature🚀] Implement ProduceAccumulator

  #906 opened 3 months ago by mxsm
  0

• [Feature🚀] Implement Produer send batch message other methods

  #902 opened 3 months ago by mxsm
  0