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