Google Git
Sign in
apache / pulsar-client-go / HEAD
  1. bddaeba fix: SendAsync doesn't respect context and can't timeout during reconnection (#1422) by Zike Yang · 7 days ago master
  2. 8fb4613 chore(deps): bump github.com/docker/docker (#1405) by dependabot[bot] · 14 days ago
  3. 555e8fc chore(deps): bump github.com/go-viper/mapstructure/v2 (#1415) by dependabot[bot] · 14 days ago
  4. cf832bb [Issue #1418] Fix: Properties not getting consistently set on pulsaradmin subscription message responses (#1419) by JamesMurkin · 14 days ago
  5. 6aa1fb6 fix: add DLQPolicy.DeadLetterTopicProducerName (#1417) by Thomas Bousquet · 3 weeks ago
  6. 230d11b Add max topics per namespace methods (#1413) by Collignon-Ducret Rémi · 3 weeks ago
  7. a5fb2fc chore: upgrade hamba/avro to v2.29.0 (#1414) by Zixuan Liu · 3 weeks ago
  8. 4392621 Fix missing topic in dlq producer name when using RetryEnable option (#1412) by zhou zhuohan · 3 weeks ago
  9. ba6468a fix: handle reconnection logic for zero queue consumer (#1404) by crossoverJie · 3 weeks ago
  10. 7a9a33c [issue #1357][producer] fix: allow multiples callbacks with concurrent producer flushes (async publish) (#1409) by Thomas Bousquet · 4 weeks ago
  11. d471a67 Change the pulsar_client_sending_buffers_count metric to client level (#1408) by Yunze Xu · 5 weeks ago
  12. 1a0bfc9 Support snappy compression (#1406) by zhou zhuohan · 5 weeks ago
  13. b12eccc [Fix] DLQ Messages will lose system properties when sent from reconsumeLater() (#1392) by zhou zhuohan · 7 weeks ago
  14. 1422129 Add changelog for 0.16.0 (#1401) by Zike Yang · 7 weeks ago
  15. 06f4dd8 fix: replace panic with proper error handling in RPC client and lookup service (#1403) by Zike Yang · 8 weeks ago
  16. 1f9e828 [Issue 1399] add eventTime in reconsumeLaterWithCustomProperties func (#1400) by Deep Onkar · 8 weeks ago
  17. 5a320e8 feat: align topics level policies admin apis to java restful apis (#1398) by Rui Fu · 8 weeks ago branch-0.16.0 v0.16.0 v0.16.0-candidate-1
  18. 0dee113 fix: add missing metric tracking of `pulsar_client_consumer_acks` for AckIDList method (#1396) by Zike Yang · 9 weeks ago
  19. 7f7fb43 ZeroQueueConsumer is not supported with RetryEnable (#1391) by crossoverJie · 9 weeks ago
  20. 67c3d53 Fix sending buffer race by using proper reference counting (#1394) by Zike Yang · 9 weeks ago
  21. 9440f18 feat: add pulsar admin namespace properties methods for PUT/GET/DELETE (#1390) by Thomas Bousquet · 2 months ago
  22. c587b5c [Issue 1384][consumer] Fix the default nack backoff policy (#1385) by Gaylor Bosson · 2 months ago
  23. 12b966d [improve] Support http lookup getSchema interface (#1368) by zhou zhuohan · 3 months ago
  24. aaadde5 [Fix] Fix backoff unit tests (#1387) by zhou zhuohan · 3 months ago
  25. 58ac256 Fix: namespace schema compatibility strategy (#1386) by Rui Fu · 3 months ago
  26. 55c71e6 chore: replace deprecated api rand.Seed (#1363) by Young Xu · 3 months ago
  27. f9363eb fix: support json token file format authentication (#1380) by Qiang Zhao · 3 months ago
  28. 5d49f15 [improve] Add Testcase to test using keyShared subscription and delayed messages at the same time (#1361) by zhou zhuohan · 3 months ago
  29. e2f46c6 [improve] Support ClientVersion in 2.x pulsar broker (#1383) by zhou zhuohan · 3 months ago
  30. faffa30 Skip very flaky TestMessageSingleRouter for now (#1382) by Yunze Xu · 3 months ago
  31. 5cdb227 Support update or remove topic properties (#1381) by Yunze Xu · 3 months ago
  32. ad9a7d1 Update the release process to update the release note on pulsar-site (#1375) by Zike Yang · 4 months ago
  33. f673e4d Improve perf with level guard in slogWrapper calls (#1374) by Gareth Murphy · 4 months ago
  34. e8bbcb4 Add changelog for 0.15.1 (#1370) by Zike Yang · 4 months ago
  35. d08cdd5 Fix the staging release process (#1373) by Zike Yang · 4 months ago
  36. a5c6dee Fix CI can't be failed even the tests are failed (#1367) by Zike Yang · 4 months ago v0.15.1 v0.15.1-candidate-2
  37. 2516598 Fix reader hanging when startMessageId is latest (#1364) by Zike Yang · 4 months ago
  38. 05c1e32 Make ZTS proxy configurable in athenz auth plugin (#1360) by Masahiro Sakamoto · 5 months ago
  39. 0e1c1d6 Add changelog for 0.15.0 (#1350) by Zike Yang · 5 months ago
  40. 6080a62 Prefetch role tokens in the background in the Athenz auth plugin (#1355) by Masahiro Sakamoto · 5 months ago
  41. 712e14c fix: use sha instead of tag for golangci/golangci-lint-action (#1352) by Zixuan Liu · 6 months ago
  42. ae3412f chore(deps): bump github.com/containerd/containerd from 1.7.18 to 1.7.27 (#1348) by dependabot[bot] · 6 months ago
  43. f868794 chore(deps): bump github.com/golang-jwt/jwt/v5 from 5.2.1 to 5.2.2 (#1349) by dependabot[bot] · 6 months ago
  44. 02ee51e [fix][sec] Bump golang.org/x/net to address CVE-2025-22870, requires go 1.23 (#1351) by Lari Hotari · 6 months ago
  45. 0ab28c2 Fix potential data race in pendingItem.done() (#1347) by gunli · 6 months ago v0.15.0 v0.15.0-candidate-2
  46. db5cb7a [docs][producer] Update deliverAfter and deliverAt api comment (#1339) by zhou zhuohan · 6 months ago
  47. 6c83f56 chore(deps): bump golang.org/x/net from 0.23.0 to 0.33.0 (#1334) by dependabot[bot] · 7 months ago
  48. 274a10f Fix: Potential data race (#1338) by gunli · 7 months ago
  49. ba83732 Fix wrong result of reader.hasNext/Next after seeking by id or time (#1340) by Baodi Shi · 7 months ago
  50. 3181aaa deps: update dependency versions (#1327) by Eugene R. · 7 months ago
  51. 042bfcd Fix: Potential data/write conflicts (#1336) by gunli · 7 months ago
  52. 802aa69 Improve message decompress error (#1342) by Zike Yang · 7 months ago
  53. 6cb2867 opt: delete redundant channel connection.incomingCmdCh (#1343) by gunli · 7 months ago
  54. 84f3677 Upgrade lz4 to v4 (#1341) by Zike Yang · 7 months ago
  55. 020b55c Chore: deprecated usages (#1329) by Collignon-Ducret Rémi · 7 months ago
  56. 4e71a47 [fix] [client] fix same producer/consumer use more than one connection per broker (#1323) by Baodi Shi · 9 months ago v0.15.0-candidate-1
  57. ffba2a8 refactor: use errors.Join to wrap multiple errors (#1322) by Eugene R. · 9 months ago
  58. 024e230 fix: wrap errors using %w to preserve context (#1321) by Eugene R. · 9 months ago
  59. 31ba011 chore(deps): bump golang.org/x/crypto from 0.22.0 to 0.31.0 (#1318) by dependabot[bot] · 9 months ago
  60. c9245bc fix: enhance transaction functionality (#1281) by Eugene R. · 9 months ago
  61. 0612938 PIP-254: Support configuring client version (#1316) by crossoverJie · 9 months ago
  62. edea3eb [Issue 1276] Fix multiple consumers using zeroQueueConsumer (#1278) by crossoverJie · 9 months ago
  63. 279e1d7 [Issue 1297][consumer] Fix DLQ producer name conflicts when there are same name consumers (#1314) by zhou zhuohan · 10 months ago
  64. 7bbb5b2 Fix close blocked (#1308) by Zixuan Liu · 10 months ago
  65. 95232de Revert #1283 and to fix possible deadlock when queueCh is full (#1311) by Baodi Shi · 10 months ago
  66. 9366a0e [Improve] Admin GetStats: Fill in missing fields (#1309) by crossoverJie · 10 months ago
  67. c369e75 Remove copy variable in goroutine loop (#1307) by crossoverJie · 10 months ago
  68. ffdc3af Improve the AckIDList performance when there are many topics subscribed (#1305) by Yunze Xu · 10 months ago
  69. a144d88 Remove unused fields and methods for internal connection (#1306) by Yunze Xu · 10 months ago
  70. 92c6e28 improve: use ctx and timer instead sleep (#1256) by Zixuan Liu · 10 months ago
  71. 35076ac Support acknowledging a list of message IDs (#1301) by Yunze Xu · 11 months ago
  72. 875f6ba fix: seek race (#1265) by Zixuan Liu · 11 months ago
  73. ccaf552 [improve] PIP-368: Support lookup based on the lookup properties (#1303) by crossoverJie · 11 months ago
  74. 8c193de Upgrade pulsar image to 4.0.0 (#1304) by crossoverJie · 11 months ago
  75. 310fb94 Bump the minimum Go version to 1.22 (#1300) by Yunze Xu · 11 months ago
  76. a7ef9ed Compatible the HTTP header properties with PIP-279 (#1299) by Baodi Shi · 11 months ago
  77. 06f2693 improve: use chan *message instead of chan []*message as queueCh (#1283) by Zixuan Liu · 12 months ago
  78. 551da2d [improve] use pulsar-client-go-test docker to run blue-green cluster test (#1287) by zhou zhuohan · 12 months ago
  79. 795c180 chore: delete unused .header file (#1295) by ZhangJian He · 12 months ago
  80. b2a6456 chore: bump hamba version from unoffical version to v2.26.0 (#1294) by ZhangJian He · 12 months ago
  81. 69a06d5 [fix] Only decompress the payload if it's not empty (#1280) by Stepan Bujnak · 12 months ago
  82. 7484c93 [improve] let tlsoptions include std tlsconfig (#1293) by dream-kzx · 12 months ago
  83. f0518c0 [pulsaradmin] Add GetAllSchemas command (#1289) by Calin Dima · 12 months ago
  84. 8f3334e Add changelog for 0.14.0 (#1288) by Zike Yang · 12 months ago
  85. 3d2c1cb [fix] fix flaky test `TestCloseFlushWithTimer` (#1292) by Zike Yang · 12 months ago
  86. 630d5f8 [fix] Reconnection logic and Backoff policy doesn't work correctly (#1197) by crossoverJie · 12 months ago v0.14.0 v0.14.0-candidate-1
  87. 188dba9 [fix] [Issue 485]Fixed crash caused by memory not aligned in arm32 architecture (#1286) by dream-kzx · 1 year ago
  88. 98dc8d4 [Issue 1272][connection] Attempt to avoid deadlock during reconnection (#1273) by Gaylor Bosson · 1 year ago
  89. 7ae0059 Refactor connection concurrency model (#1275) by Gaylor Bosson · 1 year ago
  90. be55314 [improve] stop timer when close timedAckGroupingTracker (#1279) by zhou zhuohan · 1 year, 1 month ago
  91. 953d9ea feat: support the namespace offloadThresholdInSeconds API in pulsaradmin pkg (#1271) by Eric Shen · 1 year, 1 month ago
  92. 01e32e7 chore(deps): bump github.com/docker/docker (#1269) by dependabot[bot] · 1 year, 1 month ago
  93. ab042ae [fix] peek message will return -1 for partitionIndex (#1267) by Baodi Shi · 1 year, 1 month ago
  94. 6a2e461 Add changelog for 0.13.1 (#1266) by Zike Yang · 1 year, 1 month ago
  95. dad98f1 [Improve] Add InitialSubscriptionName for DLQPolicy (#1264) by crossoverJie · 1 year, 2 months ago
  96. 8dd4ed1 [fix] Avoid a data race when flushing with load (#1261) by Gaylor Bosson · 1 year, 2 months ago
  97. fb805c0 [Issue 1259][producer] Prevent panic when calling Flush on closed producer (#1260) by Gaylor Bosson · 1 year, 2 months ago
  98. c74460d [feat] Add support for subscription expiration time namespace settings (#1254) by Kai · 1 year, 2 months ago
  99. c3b0633 [Fix] Oauth2 Client credentials flow use scopes from the keyfile as well (#1244) by Nikolaj Lund Sørensen · 1 year, 2 months ago
  100. 28293a6 fix: producer close was blocked (#1249) by Zixuan Liu · 1 year, 2 months ago