Google Git
Sign in
apache / pulsar-client-go / HEAD
  1. 203dcf1 feat(oauth2): add support for issuer URL override in client credentials flow (#1463) by Rui Fu · 8 days ago master
  2. cc18590 Implement ReconsumeLater on regex consumer (#1456) by Jordan Fitzgerald · 3 weeks ago
  3. 25af763 fix: change producer reconnect error logs to warn logs (#1445) by Zike Yang · 5 weeks ago
  4. e7f1724 Update release process to link the release and release notes to pulsar website (#1453) by Zike Yang · 5 weeks ago
  5. 3bb7d4e docs: Update example, using slog as the default logger (#1449) by zhou zhuohan · 7 weeks ago
  6. 9d65d0e feat: Add Creation and Last Publish Timestamps to Topic Stats (PIP-431) (#1451) by Penghui Li · 7 weeks ago
  7. 9f5ea52 feat(namespace): add RemovePersistence methods to namespace admin (#1447) by Rui Fu · 8 weeks ago
  8. 9785c01 fix(utils): add JSON tag for UpdateAuthData in UpdateOptions (#1450) by Rui Fu · 8 weeks ago
  9. faed695 Add changelog for 0.18.0 (#1442) by Zike Yang · 8 weeks ago
  10. 41bc6f4 fix: enhance zero queue consumer reconnection handling and message permit management (#1443) by crossoverJie · 9 weeks ago
  11. 6ab93d5 fix: return error when the client transaction coordinator is nil to p… (#1444) by Thomas Bousquet · 9 weeks ago
  12. dff07bd chore(deps): bump golang.org/x/crypto from 0.36.0 to 0.45.0 (#1440) by dependabot[bot] · 10 weeks ago v0.18.0-candidate-1
  13. 5b0e054 Support reloading OAuth2 key file (#1441) by Zike Yang · 2 months ago
  14. fa2b263 Fix partition update failure causing existing producers to close (#1437) by Zike Yang · 3 months ago
  15. 4ba6850 chore(deps): bump github.com/dvsekhvalnov/jose2go from 1.6.0 to 1.7.0 (#1439) by dependabot[bot] · 3 months ago
  16. bdfa6a0 Fix the issue of unable to parse non-batch messages that with non-empty properties and empty payloads. (#1435) by Cong Zhao · 3 months ago
  17. 148c10c add timestamp to schema info (#1436) by Rui Fu · 3 months ago
  18. 7b4b3a6 test: add unit test for unloading topic before consuming zero queue messages (#1434) by crossoverJie · 3 months ago
  19. 50efe42 Update namespace & topic admin methods to return nil if unset (#1433) by Kai · 3 months ago
  20. c0db482 Use -1 as sentinel value for namespace and topic admin commands (#1430) by Kai · 4 months ago
  21. d99d2c0 [improve] modify the negativeACK structure to reduce memory overhead (#1410) by Guangyang Deng · 4 months ago
  22. d85f096 Add changelog for 0.17.0 (#1428) by Zike Yang · 4 months ago
  23. ed7d498 fix: improve zero queue consumer support for partitioned topics (#1424) by crossoverJie · 4 months ago branch-0.17.0 v0.17.0 v0.17.0-candidate-1
  24. d19a9f8 feat: add WithContext() admin client methods (#1425) by Thomas Bousquet · 4 months ago
  25. bddaeba fix: SendAsync doesn't respect context and can't timeout during reconnection (#1422) by Zike Yang · 5 months ago
  26. 8fb4613 chore(deps): bump github.com/docker/docker (#1405) by dependabot[bot] · 5 months ago
  27. 555e8fc chore(deps): bump github.com/go-viper/mapstructure/v2 (#1415) by dependabot[bot] · 5 months ago
  28. cf832bb [Issue #1418] Fix: Properties not getting consistently set on pulsaradmin subscription message responses (#1419) by JamesMurkin · 5 months ago
  29. 6aa1fb6 fix: add DLQPolicy.DeadLetterTopicProducerName (#1417) by Thomas Bousquet · 5 months ago
  30. 230d11b Add max topics per namespace methods (#1413) by Collignon-Ducret Rémi · 5 months ago
  31. a5fb2fc chore: upgrade hamba/avro to v2.29.0 (#1414) by Zixuan Liu · 5 months ago
  32. 4392621 Fix missing topic in dlq producer name when using RetryEnable option (#1412) by zhou zhuohan · 5 months ago
  33. ba6468a fix: handle reconnection logic for zero queue consumer (#1404) by crossoverJie · 5 months ago
  34. 7a9a33c [issue #1357][producer] fix: allow multiples callbacks with concurrent producer flushes (async publish) (#1409) by Thomas Bousquet · 5 months ago
  35. d471a67 Change the pulsar_client_sending_buffers_count metric to client level (#1408) by Yunze Xu · 6 months ago
  36. 1a0bfc9 Support snappy compression (#1406) by zhou zhuohan · 6 months ago
  37. b12eccc [Fix] DLQ Messages will lose system properties when sent from reconsumeLater() (#1392) by zhou zhuohan · 6 months ago
  38. 1422129 Add changelog for 0.16.0 (#1401) by Zike Yang · 6 months ago
  39. 06f4dd8 fix: replace panic with proper error handling in RPC client and lookup service (#1403) by Zike Yang · 6 months ago
  40. 1f9e828 [Issue 1399] add eventTime in reconsumeLaterWithCustomProperties func (#1400) by Deep Onkar · 6 months ago
  41. 5a320e8 feat: align topics level policies admin apis to java restful apis (#1398) by Rui Fu · 6 months ago branch-0.16.0 v0.16.0 v0.16.0-candidate-1
  42. 0dee113 fix: add missing metric tracking of `pulsar_client_consumer_acks` for AckIDList method (#1396) by Zike Yang · 7 months ago
  43. 7f7fb43 ZeroQueueConsumer is not supported with RetryEnable (#1391) by crossoverJie · 7 months ago
  44. 67c3d53 Fix sending buffer race by using proper reference counting (#1394) by Zike Yang · 7 months ago
  45. 9440f18 feat: add pulsar admin namespace properties methods for PUT/GET/DELETE (#1390) by Thomas Bousquet · 7 months ago
  46. c587b5c [Issue 1384][consumer] Fix the default nack backoff policy (#1385) by Gaylor Bosson · 7 months ago
  47. 12b966d [improve] Support http lookup getSchema interface (#1368) by zhou zhuohan · 7 months ago
  48. aaadde5 [Fix] Fix backoff unit tests (#1387) by zhou zhuohan · 7 months ago
  49. 58ac256 Fix: namespace schema compatibility strategy (#1386) by Rui Fu · 7 months ago
  50. 55c71e6 chore: replace deprecated api rand.Seed (#1363) by Young Xu · 8 months ago
  51. f9363eb fix: support json token file format authentication (#1380) by Qiang Zhao · 8 months ago
  52. 5d49f15 [improve] Add Testcase to test using keyShared subscription and delayed messages at the same time (#1361) by zhou zhuohan · 8 months ago
  53. e2f46c6 [improve] Support ClientVersion in 2.x pulsar broker (#1383) by zhou zhuohan · 8 months ago
  54. faffa30 Skip very flaky TestMessageSingleRouter for now (#1382) by Yunze Xu · 8 months ago
  55. 5cdb227 Support update or remove topic properties (#1381) by Yunze Xu · 8 months ago
  56. ad9a7d1 Update the release process to update the release note on pulsar-site (#1375) by Zike Yang · 8 months ago
  57. f673e4d Improve perf with level guard in slogWrapper calls (#1374) by Gareth Murphy · 8 months ago
  58. e8bbcb4 Add changelog for 0.15.1 (#1370) by Zike Yang · 9 months ago
  59. d08cdd5 Fix the staging release process (#1373) by Zike Yang · 9 months ago
  60. a5c6dee Fix CI can't be failed even the tests are failed (#1367) by Zike Yang · 9 months ago v0.15.1 v0.15.1-candidate-2
  61. 2516598 Fix reader hanging when startMessageId is latest (#1364) by Zike Yang · 9 months ago
  62. 05c1e32 Make ZTS proxy configurable in athenz auth plugin (#1360) by Masahiro Sakamoto · 9 months ago
  63. 0e1c1d6 Add changelog for 0.15.0 (#1350) by Zike Yang · 10 months ago
  64. 6080a62 Prefetch role tokens in the background in the Athenz auth plugin (#1355) by Masahiro Sakamoto · 10 months ago
  65. 712e14c fix: use sha instead of tag for golangci/golangci-lint-action (#1352) by Zixuan Liu · 10 months ago
  66. ae3412f chore(deps): bump github.com/containerd/containerd from 1.7.18 to 1.7.27 (#1348) by dependabot[bot] · 10 months ago
  67. f868794 chore(deps): bump github.com/golang-jwt/jwt/v5 from 5.2.1 to 5.2.2 (#1349) by dependabot[bot] · 10 months ago
  68. 02ee51e [fix][sec] Bump golang.org/x/net to address CVE-2025-22870, requires go 1.23 (#1351) by Lari Hotari · 11 months ago
  69. 0ab28c2 Fix potential data race in pendingItem.done() (#1347) by gunli · 11 months ago v0.15.0 v0.15.0-candidate-2
  70. db5cb7a [docs][producer] Update deliverAfter and deliverAt api comment (#1339) by zhou zhuohan · 11 months ago
  71. 6c83f56 chore(deps): bump golang.org/x/net from 0.23.0 to 0.33.0 (#1334) by dependabot[bot] · 11 months ago
  72. 274a10f Fix: Potential data race (#1338) by gunli · 11 months ago
  73. ba83732 Fix wrong result of reader.hasNext/Next after seeking by id or time (#1340) by Baodi Shi · 11 months ago
  74. 3181aaa deps: update dependency versions (#1327) by Eugene R. · 11 months ago
  75. 042bfcd Fix: Potential data/write conflicts (#1336) by gunli · 11 months ago
  76. 802aa69 Improve message decompress error (#1342) by Zike Yang · 11 months ago
  77. 6cb2867 opt: delete redundant channel connection.incomingCmdCh (#1343) by gunli · 11 months ago
  78. 84f3677 Upgrade lz4 to v4 (#1341) by Zike Yang · 11 months ago
  79. 020b55c Chore: deprecated usages (#1329) by Collignon-Ducret Rémi · 12 months ago
  80. 4e71a47 [fix] [client] fix same producer/consumer use more than one connection per broker (#1323) by Baodi Shi · 1 year, 1 month ago v0.15.0-candidate-1
  81. ffba2a8 refactor: use errors.Join to wrap multiple errors (#1322) by Eugene R. · 1 year, 1 month ago
  82. 024e230 fix: wrap errors using %w to preserve context (#1321) by Eugene R. · 1 year, 2 months ago
  83. 31ba011 chore(deps): bump golang.org/x/crypto from 0.22.0 to 0.31.0 (#1318) by dependabot[bot] · 1 year, 2 months ago
  84. c9245bc fix: enhance transaction functionality (#1281) by Eugene R. · 1 year, 2 months ago
  85. 0612938 PIP-254: Support configuring client version (#1316) by crossoverJie · 1 year, 2 months ago
  86. edea3eb [Issue 1276] Fix multiple consumers using zeroQueueConsumer (#1278) by crossoverJie · 1 year, 2 months ago
  87. 279e1d7 [Issue 1297][consumer] Fix DLQ producer name conflicts when there are same name consumers (#1314) by zhou zhuohan · 1 year, 2 months ago
  88. 7bbb5b2 Fix close blocked (#1308) by Zixuan Liu · 1 year, 2 months ago
  89. 95232de Revert #1283 and to fix possible deadlock when queueCh is full (#1311) by Baodi Shi · 1 year, 2 months ago
  90. 9366a0e [Improve] Admin GetStats: Fill in missing fields (#1309) by crossoverJie · 1 year, 3 months ago
  91. c369e75 Remove copy variable in goroutine loop (#1307) by crossoverJie · 1 year, 3 months ago
  92. ffdc3af Improve the AckIDList performance when there are many topics subscribed (#1305) by Yunze Xu · 1 year, 3 months ago
  93. a144d88 Remove unused fields and methods for internal connection (#1306) by Yunze Xu · 1 year, 3 months ago
  94. 92c6e28 improve: use ctx and timer instead sleep (#1256) by Zixuan Liu · 1 year, 3 months ago
  95. 35076ac Support acknowledging a list of message IDs (#1301) by Yunze Xu · 1 year, 3 months ago
  96. 875f6ba fix: seek race (#1265) by Zixuan Liu · 1 year, 3 months ago
  97. ccaf552 [improve] PIP-368: Support lookup based on the lookup properties (#1303) by crossoverJie · 1 year, 3 months ago
  98. 8c193de Upgrade pulsar image to 4.0.0 (#1304) by crossoverJie · 1 year, 3 months ago
  99. 310fb94 Bump the minimum Go version to 1.22 (#1300) by Yunze Xu · 1 year, 3 months ago
  100. a7ef9ed Compatible the HTTP header properties with PIP-279 (#1299) by Baodi Shi · 1 year, 4 months ago