Google Git
Sign in
apache / rocketmq-client-go / HEAD
  1. 381a879 close msgCh when pq droped (#859) by dinglei · 1 year, 10 months ago
  2. 4efd770 Fix msg lost if consumer crash when send msg back failed. (#860) by dinglei · 1 year, 10 months ago
  3. d3be7e5 a liitle improvement use chan instead (#854) by hYang · 1 year, 10 months ago
  4. a05a720 fix request offset not changed in some case (#844) by cserwen · 1 year, 10 months ago
  5. ad827de add some method for pushConsumer (#849) by cserwen · 1 year, 10 months ago
  6. d802a4d fix pullThresholdSizeForTopic invalid (#814) by hjxp · 1 year, 10 months ago
  7. db78506 feat(fmt): compare slice length directly (#851) by j2gg0s · 1 year, 10 months ago
  8. 509d461 fix bug when get `mqadmin consumerStatus` can't get consume status. (#812) by WJL3333 · 1 year, 10 months ago
  9. 2b28c34 consumer consume include tag according to accumulation (#834) by wang1309 · 1 year, 10 months ago
  10. 5f33f1f fix primitive.WithMethod ctx transfer (#837) by 胡同里有猫 · 1 year, 10 months ago
  11. 7f60ab9 Remove useless code in `encodeBatch()` (#783) by Zero · 1 year, 10 months ago
  12. a7b2db6 send csListLock *sync.Mutex to computeStatsData for lock csList (#820) by liumiaomiao · 1 year, 10 months ago
  13. b2bf873 fix: takeMessages sleep 5s when no msg (#629) by Fei Yang · 1 year, 10 months ago
  14. 841f74a Merge pull request #856 from WJL3333/fix_trace_context_cancel_problem by Heng Du · 1 year, 11 months ago
  15. f56028f Merge pull request #857 from weedge/fix/selectMessageQueue_nil by Heng Du · 1 year, 11 months ago
  16. 4ed9c80 Merge pull request #858 from georgehao/fix/message_util by Heng Du · 1 year, 11 months ago
  17. a4143a1 feat: exchange messages_utils dir by georgehao · 1 year, 11 months ago
  18. 88b1b05 fix: selectMessageQueue nil *internal.TopicPublishInfo by weedge · 1 year, 11 months ago
  19. 35b951d 1. avoid cancel context too early cause trace data fail. by wangjinlong.1048576 · 1 year, 11 months ago
  20. ade7cfa Merge pull request #852 from NeonToo/fix/reset_offset by Heng Du · 1 year, 11 months ago
  21. 26e13b7 fix(sendOneWay): fix stack overflow caused by recursive calls (#773) by Wen Hu · 1 year, 11 months ago
  22. 3d93e29 bugfix rebalance is not paused after suspend and rebalance not trigged in resume by 筱瑜 · 1 year, 11 months ago
  23. d86140d [ISSUE #823]fix: panic problem caused by json-iterator in go1.18 (#841) by Yusan Kurban · 2 years ago
  24. 16443e2 [ISSUE #832] Client may submit wrong offset when network instability by AaronWang · 2 years ago
  25. a429f37 Feat/rpc request (#803) by georgehao · 2 years ago
  26. 1f541f7 Merge pull request #809 from yuz10/master by Heng Du · 2 years ago
  27. 6132b34 Merge pull request #825 from cserwen/consumer_option by Heng Du · 2 years ago
  28. 12ce1b9 Merge pull request #826 from WJL3333/support_goroutine_stack by Heng Du · 2 years ago
  29. 2d7d781 Merge pull request #829 from WJL3333/support_log_rotate by Heng Du · 2 years ago
  30. 7bc7af5 1. support rlog rotate by wangjinlong.1048576 · 2 years, 1 month ago
  31. b815a70 1. support get consumerRunningInfo return goroutine stack by wangjinlong.1048576 · 2 years, 1 month ago
  32. 3d2cd25 fix some params for consumer can not be changed by cserwen · 2 years, 1 month ago
  33. 0189e44 Merge pull request #824 from cserwen/fix_flow by Heng Du · 2 years, 1 month ago
  34. 449e940 fix queueMaxSpanFlowControlTimes not change by cserwen · 2 years, 1 month ago
  35. 853f304 Merge pull request #679 from trxo/master by zhangyang · 2 years, 1 month ago
  36. 40242bc Merge pull request #816 from WJL3333/fix_tcp_write_block by xujianhai666 · 2 years, 1 month ago
  37. 5cef32e Merge branch 'master' of github.com:apache/rocketmq-client-go by trxo · 2 years, 1 month ago
  38. b140046 1. fix ci by wangjinlong.1048576 · 2 years, 1 month ago
  39. 55b7717 1. make tcp relate param configurable by wangjinlong.1048576 · 2 years, 1 month ago
  40. 9ebb5ba 1. add log when close socket. by wangjinlong.1048576 · 2 years, 1 month ago
  41. f1913d6 1. remove request from responseTable when sendAsync by wangjinlong.1048576 · 2 years, 1 month ago
  42. b3ce4dc 1. add tcp conn write and read deadline to avoid long time block socket ops when remote endpoint crash. by wangjinlong.1048576 · 2 years, 1 month ago
  43. 2d8ce82 fix async producer example by yuz10 · 2 years, 2 months ago
  44. 7cd7fa9 [ISSUE #807] fix code style (#808) by zhangyang · 2 years, 2 months ago
  45. b7a7911 Fix the feature that GetNamesrv (#805) by guyinyou · 2 years, 2 months ago
  46. 6c97b55 [ISSUE #787]Refactor the client instance struct，converge the namesrv module (#788) by guyinyou · 2 years, 3 months ago
  47. 13e4bd6 [Issue #778] Build instance name with nanosecond (#779) by chaiyx · 2 years, 3 months ago
  48. bcd6e49 Merge pull request #775 from hnlq715/fix/update-gjson by Heng Du · 2 years, 3 months ago
  49. 43f5e5b fix: update gjson for security problem by 大可 · 2 years, 4 months ago
  50. 782b09c echo message on codecov failed to upload by dinglei · 2 years, 4 months ago
  51. 2738684 Update year to 2022. by dinglei · 2 years, 4 months ago
  52. 83f60c1 [ISSUE #759] by WJL3333 · 2 years, 5 months ago
  53. de5f561 [ISSUE #726] feat: replace fmt to rlog (#756) by yuanmoon · 2 years, 5 months ago
  54. f6cfc22 [ISSUE #757] Fix GetHeader type conflict (#758) by zhangyang · 2 years, 5 months ago
  55. 82dcf51 [ISSUE #752] change argument to pointer-like to avoid allocations by xuweiwei · 2 years, 6 months ago
  56. 35c9a53 Update stale.yml by von gosling · 2 years, 6 months ago
  57. 76a9486 Update README.md by von gosling · 2 years, 6 months ago
  58. f3f53b6 Delete .github/.github directory by von gosling · 2 years, 6 months ago
  59. e777ff4 Add workflow by vongosling · 2 years, 6 months ago
  60. 073d067 Fix building error temporarily by von gosling · 2 years, 6 months ago
  61. 5b9182a Update README.md by von gosling · 2 years, 6 months ago
  62. 613ba90 [ISSUE #744] check multiple topics in one batch by Oreoreoreo · 2 years, 6 months ago
  63. 44d8076 Remove useless comments by vongosling · 2 years, 6 months ago
  64. a9a78c5 Update README.md by von gosling · 2 years, 6 months ago
  65. d36d872 CGo version has been deprecated by von gosling · 2 years, 6 months ago
  66. a8f01df fix: correctly mark messages to be reconsumed (#693) by fluyu · 2 years, 6 months ago
  67. a8b10ce [offset] Optimize the update offset logic (#732) by zhangyang · 2 years, 7 months ago
  68. 673760e [ISSUE #735] centralized management errors (#708) by 180909 · 2 years, 7 months ago
  69. 4065610 fix the bug caused in HA cluster in consumer (#723) by guyinyou · 2 years, 9 months ago v2.1.1-rc2 v2.1.1-rc2
  70. 29d789e (fix): set subversion when #Subscribe (#720) by Robin Han · 2 years, 9 months ago
  71. 0922226 Update NOTICE by von gosling · 2 years, 9 months ago
  72. 78f607d fix the bug caused in HA cluster in pull_consumer (#717) by guyinyou · 2 years, 9 months ago
  73. 0442864 Merge pull request #712 from superhx/fix/sub_retry_topic by Heng Du · 2 years, 10 months ago
  74. 181eb30 fix the bug caused in HA cluster when master broker node is down (#714) by guyinyou · 2 years, 10 months ago
  75. befdd64 add retry topic in clustering mode by 无暮 · 2 years, 10 months ago
  76. aa08871 [ISSUE #595] Update go.mod (#706) by wenfeng · 2 years, 10 months ago
  77. 20a5c8a (fix): fix push_consumer#unsubscribe unsubscribe retry by 无暮 · 2 years, 10 months ago
  78. 077cd3b Fix send duplicate message in trace interceptor (#709) by yuz10 · 2 years, 10 months ago
  79. 46701f1 feat(internal): support reset consumer offset (#682) by 张旭 · 2 years, 10 months ago
  80. bebe20b fix: add missing log level fatal (#704) by 180909 · 2 years, 10 months ago
  81. e5d5631 [ISSUE #701] Fix timeout of SendAsync by imfan · 2 years, 11 months ago
  82. a7a7387 make consumeMessageBatchMaxSize default value consistent with java client (#660) by 张旭 · 2 years, 11 months ago
  83. e94bf49 fix: filter lookback interface for utils.ClientIP (#700) by KallyDev · 2 years, 11 months ago
  84. 8612bf7 fix: call cancel() as soon as possible to release the resources associatd with context (#691) by Berlin · 2 years, 11 months ago
  85. 2bdc662 [ISSUE #688] fix: type assert panic by Berlin · 2 years, 11 months ago
  86. 76dd050 [ISSUE #631] Support Consuming from Slave by 张旭 · 2 years, 11 months ago
  87. e69e907 [ISSUE #695] Feat: support IPV6 (#641) by 徐旭 · 2 years, 11 months ago
  88. 8f75f4b [ISSEU #683]request parameter type error fix by Git_Yang · 2 years, 11 months ago
  89. 3daa659 [ISSUE #694] Fix typos by lxc · 2 years, 11 months ago
  90. c688c19 Fix go routine leaks when consumer close with msg channel blocked (#642) by 张旭 · 3 years ago
  91. 9768869 [ISSUE #585] Fix the wrong StoreHost and GroupName with consume trace message (#586) by 张旭 · 3 years ago
  92. de657f5 (fix): wrap topic with namespace when unsubscribe (#680) by Robin Han · 3 years ago
  93. 847c11d fix msg.Body compressed and not reset, cause error in transaction message processing by trxo · 3 years ago
  94. 817ad27 Merge pull request #677 from wenfengwang/fix-init by Heng Du · 3 years ago
  95. 7993abb fix(queue-selector): fix an issue where a map read operation was not protected by the lock (#652) by czah · 3 years ago
  96. 673a8d0 Fix the usage bug of namespace (#665) by Git_Yang · 3 years ago
  97. 5168198 optimizing goroutine of Stat creation by wenfeng.wang · 3 years ago
  98. dfa26d1 Merge pull request #636 from czah/remoting-cmd-decoding-optimization by 张旭 · 3 years, 1 month ago
  99. 2d513f3 fix crash on selecting queue. (#643) by NAND86 · 3 years, 2 months ago
  100. cccc454 [ISSUE #640]fix PullInterval unit. (#639) by WeizhongTu · 3 years, 2 months ago