RocketMQ Clients - Collection of Client Bindings for Apache RocketMQ

Clone this repo:
  1. d52a5d1 Golang: Fix typo (#248) by zzjcool · 15 hours ago master
  2. afc6c40 Java: Adjust default thread num of threadpool (#247) by Aaron Ai · 3 days ago
  3. 170b2f0 Record millisecond for logging (#243) by Aaron Ai · 3 days ago
  4. 847aca7 Fix typo (#245) by Aaron Ai · 3 days ago
  5. 088a659 Add more docs for retry policy of producer (#240) by Aaron Ai · 8 days ago

RocketMQ Clients - Collection of Client Bindings for Apache RocketMQ

License CPP C# Java Golang Codecov-cpp Codecov-java Codecov-golang Maven Central


Client bindings for Apache RocketMQ, all of them follow the specification of rocketmq-apis, replacing 4.x remoting-based counterparts. Clients in this repository are built on top of Protocol Buffers and gRPC.


Provide cloud-native and robust solutions for Java, C++, C#, Golang, Rust and all other mainstream programming languages.

Features and Status

  • Ready - ✅
  • Work in progress - 🚧
Producer with standard messages🚧🚧🚧
Producer with FIFO messages🚧🚧🚧
Producer with timed/delay messages🚧🚧🚧
Producer with transactional messages🚧🚧🚧
Simple consumer🚧🚧🚧
Push consumer with concurrent message listener🚧🚧🚧🚧🚧
Push consumer with FIFO message listener🚧🚧🚧🚧🚧


Similar to other projects of Apache RocketMQ, any attempt to make this project better is welcome, including but not limited to filing a bug report, correcting type error or document writing to complete feature implementation. Do not hesitate to make a pull request if this project catches your attention.



Apache License, Version 2.0 Copyright (C) Apache Software Foundation