features
- [
32d4d09
] - feat: 支持shardingKey 客户端实现 (#109) (Orange Mi <[email protected]>)
fixes
- [
15846d4
] - fix: update name server by throttle (#108) (Gao Yang <[email protected]>)
features
- [
6bc5a62
] - feat: support consumer filter message by sql92 (#105) (#106) (Hongcai Deng <[email protected]>)
features
- [
483b4fc
] - feat: support set unitName (#101) (zōng yǔ <[email protected]>)
fixes
- [
b6ab961
] - fix: 🐛 repeat pull on same queue (#100) (Hongcai Deng <[email protected]>)
others
- [
836d9e5
] - chore: add more debug log (#87) (Hongcai Deng <[email protected]>) - [
6851d8e
] - chore: reduce error (#64) (Hongcai Deng <[email protected]>)
features
- [
207280f
] - feat: support reconsume message later (#97) (Gaara <[email protected]>)
fixes
- [
637aee4
] - fix: random-publish-queue-select-start-point (#36) (Hongcai Deng <[email protected]>)
fixes
- [
cb244b7
] - fix: use co-gather instead of p-gather (#95) (Yiyu He <[email protected]>)
features
- [
3889a0e
] - feat: support nameAddr as an array (#91) (zōng yǔ <[email protected]>)
others
- [
92892df
] - chore: adjust pulling log format (#82) (zōng yǔ <[email protected]>)
fixes
- [
456cd1f
] - fix: producer should format topic first (#81) (Hongcai Deng <[email protected]>)
fixes
- [
d477806
] - fix: close socket while pulling message timeout (#80) (zōng yǔ <[email protected]>)
others
- [
d1ca295
] - update RocketMQ link to https://rocketmq.apache.org (#79) (小雷 <[email protected]>)
fixes
- [
cb385e3
] - fix: namespace logic (#78) (zōng yǔ <[email protected]>)
fixes
- [
7e5c6a4
] - fix: not set nameSrv by default (#77) (zōng yǔ <[email protected]>)
features
- [
2cd16be
] - feat: support namespace (#75) (zōng yǔ <[email protected]>)
fixes
- [
0176223
] - fix: retry should process by broker (#73) (Hongcai Deng <[email protected]>)
others
- [
35f9341
] - chore: update test config (#74) (zōng yǔ <[email protected]>)
features
- [
073058b
] - feat: support delay deliver message (#65) (MarvinWilliam <[email protected]>)
fixes
- [
8ef9502
] - fix: drop message if reconsumeTimes > maxReconsumeTimes (#72) (zōng yǔ <[email protected]>)
others
- [
a44d4d0
] - chore: upgrade deps (#71) (zōng yǔ <[email protected]>)
features
- [
7dfe610
] - feat: support set namesrv (#61) (Hongcai Deng <[email protected]>)
features
- [
9acff9b
] - feat: support consume back (#56) (Hongcai Deng <[email protected]>)
fixes
- [
39e3782
] - fix: parse date format (#53) (Hongcai Deng <[email protected]>)
others
- [
e2dc377
] - test: fix ci (#54) (zōng yǔ <[email protected]>)
fixes
- [
d6b6fc6
] - fix: accessKeyID => accessKeyId (#50) (fengmk2 <[email protected]>)
features
- [
8ec58c8
] - feat: unify aliyun keys to accessKeyID and accessKeySecret (fengmk2 <[email protected]>)
others
- [
9ecd381
] - f (fengmk2 <[email protected]>) - [
742f269
] - f (fengmk2 <[email protected]>)
others
- [
d1de082
] - name-server-fault-tolerance (wujia <[email protected]>)
features
- [
5624319
] - feat: suppory async (ngot <[email protected]>)
others
- [
4b84644
] - test: update ci command (Hongcai Deng <[email protected]>) - [
ebb7942
] - test: trigger ci (Hongcai Deng <[email protected]>) - [
79b56c8
] - breaking: async (Hongcai Deng <[email protected]>) - [
1ee4785
] - f (ngot <[email protected]>) - [
e0a7a77
] - f (ngot <[email protected]>) - [
519e164
] - f (ngot <[email protected]>) - [
1de2b1a
] - doc: updaet readme (ngot <[email protected]>)
fixes
- [
6f78013
] - fix: fix invokeOneWay issue (gxcsoccer <[email protected]>)
others
- [
46d1bfe
] - chore: release 2.0.3 (gxcsoccer <[email protected]>),
- fix: memory leak may occurred cause by Promise.race
- doc: fix consumer and producer initialize issue
- fix: persist consumer offset issue
- fix: support subscribe before ready
- feat: add local memory store
- refactor: new consumer api
- fix: consumer offset update issue
- feat: implement ali-ons base on rocketmq #1