Google Git Google Git
Sign in
apache/pulsar-client-go/HEAD
  1. 565bcc5 [fix][test] Authenticate replication clusters test for Pulsar 5.0 (#1563) by crossoverJie · 15 hours ago master
  2. e1ed0ef [fix][tableview] Return a copy of internal data from TableView.Entries() to prevent data races and external mutation (#1544) by zhenJiangWang · 4 days ago
  3. a41b8a6 [Issue 1154][consumer] Fix bogus values in the processing time metric (#1550) by Yashvardhan Thanvi · 5 days ago
  4. 7dabb8b [fix][consumer] Release partition consumer resources after Unsubscribe (#1556) by Giorgos Karagounis · 5 days ago
  5. 7a2cf0c [Issue 1546][producer] Fix pending item ownership race in send receipt handling (#1547) by key-qinllin · 7 days ago
  6. 3bab464 [fix][producer] Recover WaitForExclusive producer fenced by stale topic epoch (#1552) by Zixuan Liu · 8 days ago
  7. 28c3453 [Issue 1298][consumer] Fix Seek to earliest or latest on non-partitioned topics (#1551) by Yashvardhan Thanvi · 8 days ago
  8. 06800d0 [fix] Bound peer-controlled sizes in the connection reader and recover from panics on connection goroutines (#1533) by zak · 9 days ago
  9. 8b026e5 [fix][table_view] Fix deadlock in IsEmpty caused by non-reentrant mutex (#1542) by zhenJiangWang · 9 days ago
  10. e3619f3 [fix][test] Make admin and transaction tests tolerant of broker behavior changes (#1545) by crossoverJie · 9 days ago
  11. a83c151 [fix][compression] Add backward compatibility for lz4 v2 uncompressed block format in Decompress (#1539) by zhenJiangWang · 5 weeks ago
  12. 1a6d7ac [improve][ci] Upgrade approved actions and check the ASF allowlist (#1538) by Lari Hotari · 5 weeks ago
  13. 61d7a95 fix(pulsaradmin): preserve explicit zero receiver queue size (#1529) by Rui Fu · 9 weeks ago
  14. fd604fa feat(pulsaradmin): add PIP-401 batchingConfig to ProducerConfig (#1530) by David Kjerrumgaard · 9 weeks ago
  15. bf4809d [fix][consumer] Use resolved partition topic for single-partition zero queue consumer (#1531) by Jiwei Guo · 9 weeks ago
  16. b47b690 [fix][consumer] Initialize batch ack tracker from the broker ack set on redelivery (#1521) by Yike Xiao · 3 months ago
  17. 8213b20 feat: add RemoveBacklogQuotaByType to namespace (#1525) by Rui Fu · 3 months ago
  18. b3d8930 fix: avoid infinite retry in blue-green migration test (#1502) by Zixuan Liu · 3 months ago
  19. 11207a8 Add changelog for 0.21.0 (#1522) by Zike Yang · 3 months ago
  20. c5b1bc1 fix: add bounds check for partition index int32 conversion (#1517) by Matteo Merli · 4 months ago branch-0.21.0 v0.21.0 v0.21.0-candidate-1
  21. ef2a631 [improve][doc] Add chunking documentation for DLQ/RLQ and add integration tests (#1511) by zhou zhuohan · 4 months ago
  22. d0dd423 Update TestContainers and change docker depenency to moby (#1513) by Frank J Kelly · 4 months ago
  23. 27e4313 [improve][client] Implement tls_client_auth for OAuth2 (#1514) by Hideaki Oguni · 4 months ago
  24. 84a5b07 Update golang to 1.25 and also update linter (#1515) by Frank J Kelly · 4 months ago
  25. 96d3050 fix: escape configuration values in UpdateDynamicConfiguration (#1505) by Kai Wang · 4 months ago
  26. b787489 feat(pulsaradmin): add offload policies API and tests (#1512) by Rui Fu · 4 months ago
  27. d7a04fa Add changelog for 0.20.0 (#1509) by Zike Yang · 5 months ago
  28. 1fe5799 [Issue #1458] Reduce unnecessary creation of retry topics and DLQ topics (#1459) by zhenJiangWang · 5 months ago
  29. 1796b8a fix: remove default case in waitWithContext to prevent busy-spin deadlock (#1503) by Zixuan Liu · 5 months ago branch-0.20.0 v0.20.0 v0.20.0-candidate-1
  30. c408a10 docs(producer): clarify SendAsync description (#1485) by Mukunda Rao Katta · 5 months ago
  31. eade693 fix: deadlock when increasing partitioned consumers (#1500) by Yunze Xu · 5 months ago
  32. a1765ef [fix][consumer] Add reconnect failure listener and auto-close on max retry exhaustion (#1490) by Pavel Zeger · 5 months ago
  33. 87ce8f9 [Issue 1094][doc] Enhance ConnectionTimeout/KeepAliveInterval comments (#1488) by zhou zhuohan · 5 months ago
  34. c2bc7e3 test: fix TestPriorityConsumer (#1495) by Zixuan Liu · 5 months ago
  35. dfdbc46 fix: fix connection panic caused by WaitGroup misuse on close (#1484) by Zixuan Liu · 6 months ago
  36. 0129b2d fix: the access to consumer.consumers might not be thread safe (#1494) by Yunze Xu · 6 months ago
  37. fe335de [feat] Add consumer PriorityLevel support (#1487) by grishaf · 6 months ago
  38. d664fcf fix: add batchIdx to messageID.String() when batched message (#1491) by adrianiacobghiula · 6 months ago
  39. 6db892c [Issue 1473][Consumer] Fix race in grabConn dropping messages before handler registration (#1476) by aleks-lazic · 6 months ago
  40. fe8aaaf [Reader] fix: deliver null-value tombstones instead of discarding them (#1482) by João Moreira Fernandes · 6 months ago
  41. a333bb9 Add release note for 0.19.0 (#1475) by Zike Yang · 7 months ago
  42. 8ea5300 fix(test): add localhost advertised address to standalone startup (#1480) by Zike Yang · 7 months ago
  43. 593fccf [Issue 1446][Consumer] Fix consumer can't consume resent chunked messages (#1464) by zhou zhuohan · 7 months ago branch-0.19.0 v0.19.0 v0.19.0-candidate-1
  44. e7eb92f feat(pulsaradmin): add scoped topic policies support (#1471) by Rui Fu · 7 months ago
  45. d0db340 improve: service URL parsing compatible with Go 1.26 (#1468) by Zixuan Liu · 7 months ago
  46. 15bd915 fix(consumer): fix panic when messages size is 0 (#1460) by unJASON · 7 months ago
  47. d7fafb5 feat: regard ProducerBlockedQuotaExceededException as retryable exception to continue to reconnect (#1457) by zhou zhuohan · 7 months ago
  48. 70d34c9 admin: add remove replication clusters topic API (#1470) by Rui Fu · 7 months ago
  49. 7832a7d feat(topic): add support for retrieving applied schema compatibility strategy (#1469) by Rui Fu · 8 months ago
  50. 3564674 feat(namespace): add removal methods for namespace policies (#1465) by Rui Fu · 8 months ago
  51. 203dcf1 feat(oauth2): add support for issuer URL override in client credentials flow (#1463) by Rui Fu · 9 months ago
  52. cc18590 Implement ReconsumeLater on regex consumer (#1456) by Jordan Fitzgerald · 9 months ago
  53. 25af763 fix: change producer reconnect error logs to warn logs (#1445) by Zike Yang · 10 months ago
  54. e7f1724 Update release process to link the release and release notes to pulsar website (#1453) by Zike Yang · 10 months ago
  55. 3bb7d4e docs: Update example, using slog as the default logger (#1449) by zhou zhuohan · 10 months ago
  56. 9d65d0e feat: Add Creation and Last Publish Timestamps to Topic Stats (PIP-431) (#1451) by Penghui Li · 11 months ago
  57. 9f5ea52 feat(namespace): add RemovePersistence methods to namespace admin (#1447) by Rui Fu · 11 months ago
  58. 9785c01 fix(utils): add JSON tag for UpdateAuthData in UpdateOptions (#1450) by Rui Fu · 11 months ago
  59. faed695 Add changelog for 0.18.0 (#1442) by Zike Yang · 11 months ago
  60. 41bc6f4 fix: enhance zero queue consumer reconnection handling and message permit management (#1443) by crossoverJie · 11 months ago
  61. 6ab93d5 fix: return error when the client transaction coordinator is nil to p… (#1444) by Thomas Bousquet · 11 months ago
  62. dff07bd chore(deps): bump golang.org/x/crypto from 0.36.0 to 0.45.0 (#1440) by dependabot[bot] · 11 months ago v0.18.0-candidate-1
  63. 5b0e054 Support reloading OAuth2 key file (#1441) by Zike Yang · 11 months ago
  64. fa2b263 Fix partition update failure causing existing producers to close (#1437) by Zike Yang · 11 months ago
  65. 4ba6850 chore(deps): bump github.com/dvsekhvalnov/jose2go from 1.6.0 to 1.7.0 (#1439) by dependabot[bot] · 12 months ago
  66. bdfa6a0 Fix the issue of unable to parse non-batch messages that with non-empty properties and empty payloads. (#1435) by Cong Zhao · 12 months ago
  67. 148c10c add timestamp to schema info (#1436) by Rui Fu · 12 months ago
  68. 7b4b3a6 test: add unit test for unloading topic before consuming zero queue messages (#1434) by crossoverJie · 12 months ago
  69. 50efe42 Update namespace & topic admin methods to return nil if unset (#1433) by Kai · 12 months ago
  70. c0db482 Use -1 as sentinel value for namespace and topic admin commands (#1430) by Kai · 1 year ago
  71. d99d2c0 [improve] modify the negativeACK structure to reduce memory overhead (#1410) by Guangyang Deng · 1 year ago
  72. d85f096 Add changelog for 0.17.0 (#1428) by Zike Yang · 1 year ago
  73. ed7d498 fix: improve zero queue consumer support for partitioned topics (#1424) by crossoverJie · 1 year, 1 month ago branch-0.17.0 v0.17.0 v0.17.0-candidate-1
  74. d19a9f8 feat: add WithContext() admin client methods (#1425) by Thomas Bousquet · 1 year, 1 month ago
  75. bddaeba fix: SendAsync doesn't respect context and can't timeout during reconnection (#1422) by Zike Yang · 1 year, 1 month ago
  76. 8fb4613 chore(deps): bump github.com/docker/docker (#1405) by dependabot[bot] · 1 year, 2 months ago
  77. 555e8fc chore(deps): bump github.com/go-viper/mapstructure/v2 (#1415) by dependabot[bot] · 1 year, 2 months ago
  78. cf832bb [Issue #1418] Fix: Properties not getting consistently set on pulsaradmin subscription message responses (#1419) by JamesMurkin · 1 year, 2 months ago
  79. 6aa1fb6 fix: add DLQPolicy.DeadLetterTopicProducerName (#1417) by Thomas Bousquet · 1 year, 2 months ago
  80. 230d11b Add max topics per namespace methods (#1413) by Collignon-Ducret Rémi · 1 year, 2 months ago
  81. a5fb2fc chore: upgrade hamba/avro to v2.29.0 (#1414) by Zixuan Liu · 1 year, 2 months ago
  82. 4392621 Fix missing topic in dlq producer name when using RetryEnable option (#1412) by zhou zhuohan · 1 year, 2 months ago
  83. ba6468a fix: handle reconnection logic for zero queue consumer (#1404) by crossoverJie · 1 year, 2 months ago
  84. 7a9a33c [issue #1357][producer] fix: allow multiples callbacks with concurrent producer flushes (async publish) (#1409) by Thomas Bousquet · 1 year, 2 months ago
  85. d471a67 Change the pulsar_client_sending_buffers_count metric to client level (#1408) by Yunze Xu · 1 year, 2 months ago
  86. 1a0bfc9 Support snappy compression (#1406) by zhou zhuohan · 1 year, 2 months ago
  87. b12eccc [Fix] DLQ Messages will lose system properties when sent from reconsumeLater() (#1392) by zhou zhuohan · 1 year, 3 months ago
  88. 1422129 Add changelog for 0.16.0 (#1401) by Zike Yang · 1 year, 3 months ago
  89. 06f4dd8 fix: replace panic with proper error handling in RPC client and lookup service (#1403) by Zike Yang · 1 year, 3 months ago
  90. 1f9e828 [Issue 1399] add eventTime in reconsumeLaterWithCustomProperties func (#1400) by Deep Onkar · 1 year, 3 months ago
  91. 5a320e8 feat: align topics level policies admin apis to java restful apis (#1398) by Rui Fu · 1 year, 3 months ago branch-0.16.0 v0.16.0 v0.16.0-candidate-1
  92. 0dee113 fix: add missing metric tracking of `pulsar_client_consumer_acks` for AckIDList method (#1396) by Zike Yang · 1 year, 3 months ago
  93. 7f7fb43 ZeroQueueConsumer is not supported with RetryEnable (#1391) by crossoverJie · 1 year, 3 months ago
  94. 67c3d53 Fix sending buffer race by using proper reference counting (#1394) by Zike Yang · 1 year, 3 months ago
  95. 9440f18 feat: add pulsar admin namespace properties methods for PUT/GET/DELETE (#1390) by Thomas Bousquet · 1 year, 4 months ago
  96. c587b5c [Issue 1384][consumer] Fix the default nack backoff policy (#1385) by Gaylor Bosson · 1 year, 4 months ago
  97. 12b966d [improve] Support http lookup getSchema interface (#1368) by zhou zhuohan · 1 year, 4 months ago
  98. aaadde5 [Fix] Fix backoff unit tests (#1387) by zhou zhuohan · 1 year, 4 months ago
  99. 58ac256 Fix: namespace schema compatibility strategy (#1386) by Rui Fu · 1 year, 4 months ago
  100. 55c71e6 chore: replace deprecated api rand.Seed (#1363) by Young Xu · 1 year, 4 months ago