Google Git
Sign in
apache/pulsar-client-go/HEAD
  1. 1fe5799 [Issue #1458] Reduce unnecessary creation of retry topics and DLQ topics (#1459) by zhenJiangWang · 2 days ago master
  2. 1796b8a fix: remove default case in waitWithContext to prevent busy-spin deadlock (#1503) by Zixuan Liu · 12 days ago branch-0.20.0 v0.20.0-candidate-1
  3. c408a10 docs(producer): clarify SendAsync description (#1485) by Mukunda Rao Katta · 2 weeks ago
  4. eade693 fix: deadlock when increasing partitioned consumers (#1500) by Yunze Xu · 3 weeks ago
  5. a1765ef [fix][consumer] Add reconnect failure listener and auto-close on max retry exhaustion (#1490) by Pavel Zeger · 3 weeks ago
  6. 87ce8f9 [Issue 1094][doc] Enhance ConnectionTimeout/KeepAliveInterval comments (#1488) by zhou zhuohan · 4 weeks ago
  7. c2bc7e3 test: fix TestPriorityConsumer (#1495) by Zixuan Liu · 4 weeks ago
  8. dfdbc46 fix: fix connection panic caused by WaitGroup misuse on close (#1484) by Zixuan Liu · 4 weeks ago
  9. 0129b2d fix: the access to consumer.consumers might not be thread safe (#1494) by Yunze Xu · 4 weeks ago
  10. fe335de [feat] Add consumer PriorityLevel support (#1487) by grishaf · 5 weeks ago
  11. d664fcf fix: add batchIdx to messageID.String() when batched message (#1491) by adrianiacobghiula · 5 weeks ago
  12. 6db892c [Issue 1473][Consumer] Fix race in grabConn dropping messages before handler registration (#1476) by aleks-lazic · 5 weeks ago
  13. fe8aaaf [Reader] fix: deliver null-value tombstones instead of discarding them (#1482) by João Moreira Fernandes · 7 weeks ago
  14. a333bb9 Add release note for 0.19.0 (#1475) by Zike Yang · 8 weeks ago
  15. 8ea5300 fix(test): add localhost advertised address to standalone startup (#1480) by Zike Yang · 8 weeks ago
  16. 593fccf [Issue 1446][Consumer] Fix consumer can't consume resent chunked messages (#1464) by zhou zhuohan · 3 months ago branch-0.19.0 v0.19.0 v0.19.0-candidate-1
  17. e7eb92f feat(pulsaradmin): add scoped topic policies support (#1471) by Rui Fu · 3 months ago
  18. d0db340 improve: service URL parsing compatible with Go 1.26 (#1468) by Zixuan Liu · 3 months ago
  19. 15bd915 fix(consumer): fix panic when messages size is 0 (#1460) by unJASON · 3 months ago
  20. d7fafb5 feat: regard ProducerBlockedQuotaExceededException as retryable exception to continue to reconnect (#1457) by zhou zhuohan · 3 months ago
  21. 70d34c9 admin: add remove replication clusters topic API (#1470) by Rui Fu · 3 months ago
  22. 7832a7d feat(topic): add support for retrieving applied schema compatibility strategy (#1469) by Rui Fu · 3 months ago
  23. 3564674 feat(namespace): add removal methods for namespace policies (#1465) by Rui Fu · 4 months ago
  24. 203dcf1 feat(oauth2): add support for issuer URL override in client credentials flow (#1463) by Rui Fu · 4 months ago
  25. cc18590 Implement ReconsumeLater on regex consumer (#1456) by Jordan Fitzgerald · 5 months ago
  26. 25af763 fix: change producer reconnect error logs to warn logs (#1445) by Zike Yang · 5 months ago
  27. e7f1724 Update release process to link the release and release notes to pulsar website (#1453) by Zike Yang · 5 months ago
  28. 3bb7d4e docs: Update example, using slog as the default logger (#1449) by zhou zhuohan · 6 months ago
  29. 9d65d0e feat: Add Creation and Last Publish Timestamps to Topic Stats (PIP-431) (#1451) by Penghui Li · 6 months ago
  30. 9f5ea52 feat(namespace): add RemovePersistence methods to namespace admin (#1447) by Rui Fu · 6 months ago
  31. 9785c01 fix(utils): add JSON tag for UpdateAuthData in UpdateOptions (#1450) by Rui Fu · 6 months ago
  32. faed695 Add changelog for 0.18.0 (#1442) by Zike Yang · 6 months ago
  33. 41bc6f4 fix: enhance zero queue consumer reconnection handling and message permit management (#1443) by crossoverJie · 6 months ago
  34. 6ab93d5 fix: return error when the client transaction coordinator is nil to p… (#1444) by Thomas Bousquet · 6 months ago
  35. dff07bd chore(deps): bump golang.org/x/crypto from 0.36.0 to 0.45.0 (#1440) by dependabot[bot] · 6 months ago v0.18.0-candidate-1
  36. 5b0e054 Support reloading OAuth2 key file (#1441) by Zike Yang · 7 months ago
  37. fa2b263 Fix partition update failure causing existing producers to close (#1437) by Zike Yang · 7 months ago
  38. 4ba6850 chore(deps): bump github.com/dvsekhvalnov/jose2go from 1.6.0 to 1.7.0 (#1439) by dependabot[bot] · 7 months ago
  39. bdfa6a0 Fix the issue of unable to parse non-batch messages that with non-empty properties and empty payloads. (#1435) by Cong Zhao · 7 months ago
  40. 148c10c add timestamp to schema info (#1436) by Rui Fu · 7 months ago
  41. 7b4b3a6 test: add unit test for unloading topic before consuming zero queue messages (#1434) by crossoverJie · 8 months ago
  42. 50efe42 Update namespace & topic admin methods to return nil if unset (#1433) by Kai · 8 months ago
  43. c0db482 Use -1 as sentinel value for namespace and topic admin commands (#1430) by Kai · 8 months ago
  44. d99d2c0 [improve] modify the negativeACK structure to reduce memory overhead (#1410) by Guangyang Deng · 8 months ago
  45. d85f096 Add changelog for 0.17.0 (#1428) by Zike Yang · 8 months ago
  46. ed7d498 fix: improve zero queue consumer support for partitioned topics (#1424) by crossoverJie · 8 months ago branch-0.17.0 v0.17.0 v0.17.0-candidate-1
  47. d19a9f8 feat: add WithContext() admin client methods (#1425) by Thomas Bousquet · 8 months ago
  48. bddaeba fix: SendAsync doesn't respect context and can't timeout during reconnection (#1422) by Zike Yang · 9 months ago
  49. 8fb4613 chore(deps): bump github.com/docker/docker (#1405) by dependabot[bot] · 9 months ago
  50. 555e8fc chore(deps): bump github.com/go-viper/mapstructure/v2 (#1415) by dependabot[bot] · 9 months ago
  51. cf832bb [Issue #1418] Fix: Properties not getting consistently set on pulsaradmin subscription message responses (#1419) by JamesMurkin · 9 months ago
  52. 6aa1fb6 fix: add DLQPolicy.DeadLetterTopicProducerName (#1417) by Thomas Bousquet · 9 months ago
  53. 230d11b Add max topics per namespace methods (#1413) by Collignon-Ducret Rémi · 9 months ago
  54. a5fb2fc chore: upgrade hamba/avro to v2.29.0 (#1414) by Zixuan Liu · 10 months ago
  55. 4392621 Fix missing topic in dlq producer name when using RetryEnable option (#1412) by zhou zhuohan · 10 months ago
  56. ba6468a fix: handle reconnection logic for zero queue consumer (#1404) by crossoverJie · 10 months ago
  57. 7a9a33c [issue #1357][producer] fix: allow multiples callbacks with concurrent producer flushes (async publish) (#1409) by Thomas Bousquet · 10 months ago
  58. d471a67 Change the pulsar_client_sending_buffers_count metric to client level (#1408) by Yunze Xu · 10 months ago
  59. 1a0bfc9 Support snappy compression (#1406) by zhou zhuohan · 10 months ago
  60. b12eccc [Fix] DLQ Messages will lose system properties when sent from reconsumeLater() (#1392) by zhou zhuohan · 10 months ago
  61. 1422129 Add changelog for 0.16.0 (#1401) by Zike Yang · 10 months ago
  62. 06f4dd8 fix: replace panic with proper error handling in RPC client and lookup service (#1403) by Zike Yang · 11 months ago
  63. 1f9e828 [Issue 1399] add eventTime in reconsumeLaterWithCustomProperties func (#1400) by Deep Onkar · 11 months ago
  64. 5a320e8 feat: align topics level policies admin apis to java restful apis (#1398) by Rui Fu · 11 months ago branch-0.16.0 v0.16.0 v0.16.0-candidate-1
  65. 0dee113 fix: add missing metric tracking of `pulsar_client_consumer_acks` for AckIDList method (#1396) by Zike Yang · 11 months ago
  66. 7f7fb43 ZeroQueueConsumer is not supported with RetryEnable (#1391) by crossoverJie · 11 months ago
  67. 67c3d53 Fix sending buffer race by using proper reference counting (#1394) by Zike Yang · 11 months ago
  68. 9440f18 feat: add pulsar admin namespace properties methods for PUT/GET/DELETE (#1390) by Thomas Bousquet · 11 months ago
  69. c587b5c [Issue 1384][consumer] Fix the default nack backoff policy (#1385) by Gaylor Bosson · 11 months ago
  70. 12b966d [improve] Support http lookup getSchema interface (#1368) by zhou zhuohan · 12 months ago
  71. aaadde5 [Fix] Fix backoff unit tests (#1387) by zhou zhuohan · 12 months ago
  72. 58ac256 Fix: namespace schema compatibility strategy (#1386) by Rui Fu · 12 months ago
  73. 55c71e6 chore: replace deprecated api rand.Seed (#1363) by Young Xu · 12 months ago
  74. f9363eb fix: support json token file format authentication (#1380) by Qiang Zhao · 1 year ago
  75. 5d49f15 [improve] Add Testcase to test using keyShared subscription and delayed messages at the same time (#1361) by zhou zhuohan · 1 year ago
  76. e2f46c6 [improve] Support ClientVersion in 2.x pulsar broker (#1383) by zhou zhuohan · 1 year ago
  77. faffa30 Skip very flaky TestMessageSingleRouter for now (#1382) by Yunze Xu · 1 year ago
  78. 5cdb227 Support update or remove topic properties (#1381) by Yunze Xu · 1 year ago
  79. ad9a7d1 Update the release process to update the release note on pulsar-site (#1375) by Zike Yang · 1 year ago
  80. f673e4d Improve perf with level guard in slogWrapper calls (#1374) by Gareth Murphy · 1 year ago
  81. e8bbcb4 Add changelog for 0.15.1 (#1370) by Zike Yang · 1 year, 1 month ago
  82. d08cdd5 Fix the staging release process (#1373) by Zike Yang · 1 year, 1 month ago
  83. a5c6dee Fix CI can't be failed even the tests are failed (#1367) by Zike Yang · 1 year, 1 month ago v0.15.1 v0.15.1-candidate-2
  84. 2516598 Fix reader hanging when startMessageId is latest (#1364) by Zike Yang · 1 year, 1 month ago
  85. 05c1e32 Make ZTS proxy configurable in athenz auth plugin (#1360) by Masahiro Sakamoto · 1 year, 1 month ago
  86. 0e1c1d6 Add changelog for 0.15.0 (#1350) by Zike Yang · 1 year, 2 months ago
  87. 6080a62 Prefetch role tokens in the background in the Athenz auth plugin (#1355) by Masahiro Sakamoto · 1 year, 2 months ago
  88. 712e14c fix: use sha instead of tag for golangci/golangci-lint-action (#1352) by Zixuan Liu · 1 year, 2 months ago
  89. ae3412f chore(deps): bump github.com/containerd/containerd from 1.7.18 to 1.7.27 (#1348) by dependabot[bot] · 1 year, 3 months ago
  90. f868794 chore(deps): bump github.com/golang-jwt/jwt/v5 from 5.2.1 to 5.2.2 (#1349) by dependabot[bot] · 1 year, 3 months ago
  91. 02ee51e [fix][sec] Bump golang.org/x/net to address CVE-2025-22870, requires go 1.23 (#1351) by Lari Hotari · 1 year, 3 months ago
  92. 0ab28c2 Fix potential data race in pendingItem.done() (#1347) by gunli · 1 year, 3 months ago v0.15.0 v0.15.0-candidate-2
  93. db5cb7a [docs][producer] Update deliverAfter and deliverAt api comment (#1339) by zhou zhuohan · 1 year, 3 months ago
  94. 6c83f56 chore(deps): bump golang.org/x/net from 0.23.0 to 0.33.0 (#1334) by dependabot[bot] · 1 year, 3 months ago
  95. 274a10f Fix: Potential data race (#1338) by gunli · 1 year, 3 months ago
  96. ba83732 Fix wrong result of reader.hasNext/Next after seeking by id or time (#1340) by Baodi Shi · 1 year, 3 months ago
  97. 3181aaa deps: update dependency versions (#1327) by Eugene R. · 1 year, 3 months ago
  98. 042bfcd Fix: Potential data/write conflicts (#1336) by gunli · 1 year, 3 months ago
  99. 802aa69 Improve message decompress error (#1342) by Zike Yang · 1 year, 3 months ago
  100. 6cb2867 opt: delete redundant channel connection.incomingCmdCh (#1343) by gunli · 1 year, 3 months ago