1. 1d3a9cc Encryption support producer (#560) by Garule Prabhudas · 3 weeks ago master
  2. 6837964 fix: retry assertion (#599) by cimura · 3 weeks ago
  3. b684151 Fix panic when scale down partitions (#601) by xiaolong ran · 4 weeks ago
  4. 1a3ad70 Fix missing metrics for topics by registration of existing collector (#600) by pkutilina · 4 weeks ago
  5. baaf68d Fix producer panic by oldProducers (#598) by xiaolong ran · 4 weeks ago
  6. bbffae2 [issue 587] fail all pending requests when occurs ServerError_TopicTerminated… (#588) by Lei Zhiyuan · 5 weeks ago
  7. 887853e add epoch to handle create producer timeout (#582) by Rui Fu · 6 weeks ago
  8. 4b5ad9b Fix data race issue in ServiceNameResolver (#581) by Yuri Mizushima · 6 weeks ago
  9. 2109f3d [issue 585] retryRouter should Nack this message if error is not nil (#586) by Lei Zhiyuan · 6 weeks ago
  10. 29414db [issue 574] Fix handle send error panic (#576) by cckellogg · 8 weeks ago
  11. 1cd38b3 Update change log for 0.6.0 release (#570) by xiaolong ran · 8 weeks ago
  12. 5e37108 update version to 0.6.0 (#572) by xiaolong ran · 8 weeks ago
  13. bbee640 [issue 490] Add error log when schema encode failed. (#571) by Zhiqiang Li · 9 weeks ago
  14. 1dfb8fd Add producer check state before send msg. (#569) by Zhiqiang Li · 9 weeks ago
  15. 5e88b01 Add license file for depend libs (#567) by xiaolong ran · 9 weeks ago branch-0.6.0 v0.6.0 v0.6.0-candidate-1
  16. 179060f [Issue 527] fix send goroutine blocked (#530) by jiangbo9510 · 9 weeks ago
  17. f193975 Add send error logic for connection (#566) by xiaolong ran · 10 weeks ago
  18. 58ee244 [issue 516]Add lock for compressionProviders to fix data race problem (#533) by yukun · 2 months ago
  19. 7e16f6b Update proto file (#562) by xiaolong ran · 2 months ago
  20. d395583 Fix default connection timeout (#563) by xiaolong ran · 2 months ago
  21. 9d864c2 Fix possible race condition in connection pool (#561) by cckellogg · 2 months ago
  22. 0de4792 Add open tracing to pulsar go clinet (#518) by Marais · 2 months ago
  23. 7a60a7e add base package for encryption (#555) by Prabhudas · 3 months ago
  24. 3e091ae Simplify connection close logic (#559) by cckellogg · 3 months ago
  25. 8139a2c Fix panic() in internal/connection when writing to a closed channel during close (#539) by dferstay · 3 months ago
  26. 1a9f356 Add jitter to exponential backoff (#556) (#557) by Denis Vergnes · 3 months ago
  27. ea3e054 Fix channel data race (#558) by xiaolong ran · 3 months ago
  28. 0f3e504 Producer respects Context passed to Send() and SendAsync() when applying backpressure (#534) by dferstay · 3 months ago
  29. 641cb9d updating comments to conform to golang comment specification (#532) by Deen · 3 months ago
  30. 96ce2de Fix data race while accessing connection in partitionConsumer (#535) by dferstay · 3 months ago
  31. f33b594 support DisableReplication (#543) by Yuto Furuta · 3 months ago
  32. 98338e5 fix resend pendingItems race condition (#551) by Rui Fu · 3 months ago
  33. d7b4299 regenerate the certs to work with Pulsar 2.8.0 and Java 11 (#548) by Rui Fu · 3 months ago
  34. 55c15ef #540 fix lookup service not implemented GetTopicsOfNamespace (#541) by Rui Fu · 3 months ago
  35. 579984e Release locks before calling producer consumer response callbacks. (#542) by cckellogg · 3 months ago
  36. cb72395 fix nil pointer error with `GetPartitionedTopicMetadata` (#536) by Rui Fu · 3 months ago
  37. 8a78d2c fix: timeout guarantee for RequestOnCnx (#492) by jony montana · 4 months ago
  38. a03349a add LedgerId,EntryId,BatchIdx,PartitionIdx func for MessageId interface (#529) by yorkxyzhang · 4 months ago
  39. 07006de [bug] Fix reader latest position (#525) by Addison Higham · 4 months ago
  40. 6607ef8 Fixed Athenz repository name (#522) by Matteo Merli · 4 months ago
  41. 320b42c update jwt-go dependency to resolve vulnerabilities (#524) by xdingsplk · 4 months ago
  42. dd7cc9a Update changelog to 0.5.0 (#523) by xiaolong ran · 4 months ago
  43. af9d58e Always check connection close channell, before attempting to put requests (#521) by Matteo Merli · 4 months ago
  44. 6426d39 Make PartitionsAutoDiscoveryInterval configurable (#514) by Chen Liu · 4 months ago
  45. 203f2f6 use pulsar-test-infra/pulsarbot (#487) by Rui Fu · 5 months ago
  46. eebdab8 fix leak error (#499) by godchen · 5 months ago
  47. ec40d79 [#504] add http lookup service support (#510) by Rui Fu · 5 months ago
  48. b4ec53c fix: add sentAt when put item into pendingQueue (#509) by jony montana · 5 months ago
  49. f17deac Support listener name for go client (#502) by xiaolong ran · 6 months ago
  50. 6ab17dc Fix race condition/goroutine leak in partition discovery goroutine (#474) by PowerStateFailure · 6 months ago
  51. 4d6c151 Close cnxPool when closing a Client (#494) by XuanYang-cn · 6 months ago
  52. 5fb7f55 [Issue 177] add multiple hosts support (#484) by Rui Fu · 7 months ago
  53. 2e1f9c4 fix: use newError to build return error (#471) by jony montana · 7 months ago
  54. 21bd87e Improve error log for frame size too big and maxMessageSize (#459) by Ming · 7 months ago
  55. f6754a0 [fix #472] move GetPartitionedTopicMetadata to lookup service (#478) by Rui Fu · 7 months ago
  56. cd210a1 fix: batch flush method (#476) by jony montana · 7 months ago
  57. 86fab51 Update 0.4.0 changelog file (#463) by xiaolong ran · 7 months ago
  58. aca43f6 Update jwt-go version to v4 (#481) by fanjeff · 7 months ago
  59. 9546a17 Reverted datadog to DataDog (#465) by Pavel · 7 months ago
  60. af91e9c Fix unexpected nil pointer when reading iterm from keyring (#470) by Yong Zhang · 7 months ago
  61. 7d53914 Fix reader with start latest message id inclusive (#329) (#467) by Rueian · 7 months ago
  62. 25f3075 Fix unsubscribe blocked when consumer is closing or has closed (#457) by wuYin · 7 months ago branch-0.4.0 v0.4.0 v0.4.0-candidate-1
  63. 0e76dc2 asynchronized send timeout checking (#460) by wuYin · 7 months ago
  64. 6548277 fix: KeyFileTypeServiceAccount not found compile error (#455) by jony montana · 8 months ago
  65. 58a327d Issue #448 make state thread safe in consumer_partition and connection (#451) by Ming · 8 months ago
  66. c24191b Clearing message queues after seek requests (#419) by Miloš Matijašević · 8 months ago
  67. a1dca8c Logging what really caused lookup failure (#450) by wuYin · 8 months ago
  68. 462394f Fix logrusWrapper shrink interfaces slice into an interface (#449) by wuYin · 8 months ago
  69. f9d22d4 Upgrade gogo/protobuf to 1.3.2 (#446) by hrsakai · 8 months ago
  70. 2456729 [issue 438] reader.HasNext() returns true on empty topic (#441) by Ming · 8 months ago
  71. 71cc54f support jwt and trusted cert for pulsar perf client (#428) by Ming · 9 months ago
  72. fb10d4f deduplicate user topics before using them (#426) by wuYin · 9 months ago
  73. 2ee34f3 fix retry policy not effective with partitioned topic (#425) by wuYin · 9 months ago
  74. 9b20cc0 [Issue #401] Add orderingKey apis (#427) by Rui Fu · 9 months ago
  75. c187548 fix leaked nack tracker goroutine (#418) by Ming · 9 months ago
  76. 26d085a Removed unused `import "C"` statement (#416) by Matteo Merli · 9 months ago
  77. a0f59a3 Renamed Metrics.RpcRequestCount to RPCRequestCount to conform to style check (#417) by Matteo Merli · 9 months ago
  78. 0e48f3b Fix discard unacked messages (#413) by hrsakai · 9 months ago
  79. 0296890 Fixed logic to attempt reconnections to same broker (#414) by Matteo Merli · 9 months ago
  80. 110b99d Reduce the default TCP connection timeout from 30 to 5 seconds (#415) by Matteo Merli · 9 months ago
  81. 4d6848d close dangling autoDiscovery goroutine in consumer (#411) by Ming · 9 months ago
  82. 21541d6 Attach topic and custom labels to Prometheus metrics (#410) by Matteo Merli · 9 months ago
  83. 9fe66ed Read the clock fewer times during message routing (#408) by dferstay · 10 months ago
  84. 154bff0 [Issue 172] Add key based batcher (#400) by Rui Fu · 10 months ago
  85. 3fefe19 Add const client label to metrics (#406) by cckellogg · 10 months ago
  86. d84c4b4 Add error label to publish errors metric (#405) by cckellogg · 10 months ago
  87. dd67019 Update go-keyring to v1.1.6 to remove warnings on MacOS Catalina+ (#404) by Pavel · 10 months ago
  88. 2490435 Support sendTimeout (#394) by wuYin · 10 months ago
  89. b8bd55b Add metric for internal publish latency (#397) by cckellogg · 10 months ago
  90. 82e676e Fix bot action ci yaml fie (#395) by xiaolong ran · 10 months ago
  91. c961ad0 update release process (#391) by xiaolong ran · 10 months ago
  92. 8ff27ae Update changelogs for 0.3.0 (#388) by xiaolong ran · 10 months ago v0.3.0
  93. 8465c55 Fix reconsume broken while using non-FQDN topics (#386) by wuYin · 11 months ago branch-0.3.0 v0.3.0-candidate-1
  94. 793ea91 Replaced github.com/DataDog/zstd with github.com/datadog/zstd (#385) by Pavel · 11 months ago
  95. 45c522d Add schema logic in producer and consumer (#368) by xiaolong ran · 11 months ago
  96. 44b8b4e feat: support limit the retry number of reconnectToBroker (#360) by jony montana · 11 months ago
  97. 16fea6d Update default router to switch partition on all batching thresholds #382 (#383) by Denis Vergnes · 11 months ago
  98. 85a9fe8 Fix maxMessageSize not effective even if aligned with broker (#381) by wuYin · 11 months ago
  99. 02b244e Fix producer deadlock after write failure (#378) by Matteo Merli · 12 months ago
  100. c03f45f Fix deadlock when connection closed (#376) by Jia Zhai · 12 months ago