Google Git
Sign in
apache / pulsar-client-go / HEAD
  1. fc390a6 Expose EventTime consistently as a non-pointer (#186) by Matteo Merli · 4 years, 3 months ago
  2. be8ad8d Dead letter queue implementation (#184) by Matteo Merli · 4 years, 3 months ago
  3. d9d535c Fix nil pointer dereference in PartitionMetadataResponse (#182) by 冉小龙 · 4 years, 3 months ago
  4. 1ccc5de Add seek by time (#180) by 冉小龙 · 4 years, 3 months ago
  5. f41441f [Issue-148][pulsar-client-go] add seek by messageID (#168) by steven.wang · 4 years, 3 months ago
  6. ad16fa2 Fix concurrent map read and map write (#179) by 冉小龙 · 4 years, 3 months ago
  7. 6943327 PIP-55: Refresh auth credentials (#176) by Matteo Merli · 4 years, 3 months ago
  8. 4d788d9 [Issue #153] Fix handler memory leak (#154) by Rui Fu · 4 years, 4 months ago
  9. 6a08460 Fix partition key not set in batch builder (#175) by 冉小龙 · 4 years, 4 months ago
  10. e78a368 [Issue:173] Fix logrus crash (#174) by 冉小龙 · 4 years, 4 months ago
  11. 9b739cf Enable Github Action CI (#170) by 冉小龙 · 4 years, 4 months ago
  12. ba9ec93 Create go.yml by 冉小龙 · 4 years, 4 months ago
  13. 74bde94 res channel causes connection.Run() to block When request timeout occuers (#167) by dsmlily · 4 years, 4 months ago
  14. 5603a6a Fix: producer code example (#166) by Mickaël FORTUNATO · 4 years, 4 months ago
  15. 86c3e80 Add retry logic when get connection error (#157) by 冉小龙 · 4 years, 4 months ago
  16. 71d81b6 Topic reader implementation (#158) by Matteo Merli · 4 years, 4 months ago
  17. e7b779c Fixed memory leak of connection (#165) by 冉小龙 · 4 years, 4 months ago
  18. 0a496cc Set delay delivery when publishing a message (#160) by Matteo Merli · 4 years, 4 months ago
  19. 4ad9cef Fixed reading from connection (#163) by Matteo Merli · 4 years, 4 months ago
  20. d2a30f5 Avoid double cnx close notification on graceful server side close (#162) by Matteo Merli · 4 years, 4 months ago
  21. d6b14c6 Fixed the connection pool logic (#161) by Matteo Merli · 4 years, 4 months ago
  22. bb3c121 Remove maligned check from linter. (#159) by cckellogg · 4 years, 4 months ago
  23. 12a6a03 [Issue #145] fix producer cannot connect to broker through pulsar proxy (#146) by Rui Fu · 4 years, 4 months ago
  24. 5004b5d Enable golangci lint for project (#138) by 冉小龙 · 4 years, 4 months ago
  25. aaea614 Make producer.Send() to also return MessageID (#141) by Matteo Merli · 4 years, 4 months ago
  26. a6231f5 [Issue 140] Consumer should not block on received if closed. (#142) by cckellogg · 4 years, 4 months ago
  27. b354cb8 Implemented the operation timeout check (#139) by Matteo Merli · 4 years, 4 months ago
  28. cfe87b3 Use the specified connection timeout when creating connections (#137) by Matteo Merli · 4 years, 5 months ago
  29. 13d4581 Removed SendTimeout from producer options (#136) by Matteo Merli · 4 years, 5 months ago
  30. 322faca Allow to specify a function that supply a token (#130) by Matteo Merli · 4 years, 5 months ago
  31. 1cefc00 Exit go routine when signal is caught. (#134) by cckellogg · 4 years, 5 months ago
  32. e9b28ec Removed unused config options (#133) by Matteo Merli · 4 years, 5 months ago
  33. de66846 Move pkg stuff under pulsar/internal (#132) by Matteo Merli · 4 years, 5 months ago
  34. 1ac8a8b Fixed detection and handling of stale connections (#131) by Matteo Merli · 4 years, 5 months ago
  35. 4ffced1 fix requestID using consumerID && loopclosure issue && add old style topic support (#128) by hailang.wei · 4 years, 5 months ago
  36. 6253fae Add lib license files for pulsar-client-go (#126) by 冉小龙 · 4 years, 5 months ago
  37. 85bbf45 [Issue #123] Ensure message is sent if no room in current batch. (#124) by cckellogg · 4 years, 5 months ago
  38. eb9b69e Make nack tracker tests more robust. (#122) by cckellogg · 4 years, 5 months ago
  39. dfc17ab [Issue 118][client_impl.go] fix race condition when accessing client.handlers (#119) by Jim Lambert · 4 years, 5 months ago
  40. a174537 Add metadata to produce and subscribe commands. (#117) by cckellogg · 4 years, 5 months ago
  41. e65b479 move license_test from project root; change package name (#116) by Reugn · 4 years, 5 months ago
  42. 9ce7c6f Fix #111: set consumer options (#113) by Reugn · 4 years, 5 months ago
  43. 862285f Fix seg fault when producer with same name is created. (#110) by cckellogg · 4 years, 5 months ago
  44. 4328f1b Fix subscriber bug and use Consumer interface for multi topic consumer. (#109) by cckellogg · 4 years, 5 months ago
  45. ae057bd Fix repository link (#106) by Reugn · 4 years, 5 months ago
  46. 9620e75 Set error only if not nil (#105) by Reugn · 4 years, 5 months ago
  47. c809833 Add regex consumer. (#104) by cckellogg · 4 years, 5 months ago
  48. a73f643 Update protobuf file. (#103) by cckellogg · 4 years, 6 months ago
  49. a0d96c8 Updated zstd go library to avoid cgo dependency for compression (#102) by Matteo Merli · 4 years, 6 months ago
  50. d91a2a2 Add client function to list topics in a namespace. (#101) by cckellogg · 4 years, 6 months ago
  51. 55b9a6f Add multi topic consumer. (#100) by cckellogg · 4 years, 6 months ago
  52. ccd4547 Implemented decompression on consumer side (#98) by Matteo Merli · 4 years, 6 months ago
  53. ee76277 Remove error return on Close() methods (#99) by Matteo Merli · 4 years, 6 months ago
  54. 1e9d4d5 Added integrration test for acks and nacks (#97) by Matteo Merli · 4 years, 6 months ago
  55. 7b29177 Hook up ack tracking to message ids. (#96) by cckellogg · 4 years, 6 months ago
  56. 215023a Fixed RpcClient.RequestOnCnxNoWait() to not require a request id (#95) by Matteo Merli · 4 years, 6 months ago
  57. 71bec03 Added negative acks tracker and integration (#94) by Matteo Merli · 4 years, 6 months ago
  58. 367984a Removed unacked messages tracker (#90) by Matteo Merli · 4 years, 6 months ago
  59. 163fba0 Make starting the pprof server optional. (#91) by cckellogg · 4 years, 6 months ago
  60. 1325df1 Move util files to internal so they are not exported. (#93) by cckellogg · 4 years, 6 months ago
  61. 91906f5 [ISSUE #87] Ensure all producer partitions are closed. (#92) by cckellogg · 4 years, 6 months ago
  62. 34a8f81 Use internal.Buffer() for message metadata parsing (#89) by Matteo Merli · 4 years, 6 months ago
  63. 39d7cdc Simplify and refactor parts of the single topic consumer. (#86) by cckellogg · 4 years, 6 months ago
  64. 1eb64f0 Added a message id tracker for acking messages that are batched. (#82) by cckellogg · 4 years, 6 months ago
  65. af5c6d7 Switch to OpenJDK for CI (#85) by Matteo Merli · 4 years, 6 months ago
  66. 3378790 Fixed locking between connection_reader and connection (#84) by Matteo Merli · 4 years, 6 months ago
  67. 94184ea Improve and fix message parsing. (#80) by cckellogg · 4 years, 6 months ago
  68. 77dccea Handle RPC errors in reconnections (#83) by Matteo Merli · 4 years, 6 months ago
  69. d645f94 Remove usage of global consumer vars. (#79) by cckellogg · 4 years, 6 months ago
  70. d994347 Add race detection to ci testing.' (#78) by cckellogg · 4 years, 6 months ago
  71. bd30a32 [ISSUE #72] Fix data race conditions. (#77) by cckellogg · 4 years, 6 months ago
  72. 84fb576 refactor: gofmt code (#75) by xujianhai666 · 4 years, 6 months ago
  73. 8a2ff05 fix: avoid assert panic (#73) by xujianhai666 · 4 years, 6 months ago
  74. ad46ac8 Add license check for project (#71) by 冉小龙 · 4 years, 7 months ago
  75. 6138893 refactor: remove extra timeout param (#67) by xujianhai666 · 4 years, 7 months ago
  76. 702405f (refactor)clean code (#70) by xujianhai666 · 4 years, 7 months ago
  77. 11755b2 enable to specify the sequenceID (#62) by banishee · 4 years, 8 months ago
  78. de147fa Add some test cases for project (#58) by 冉小龙 · 4 years, 9 months ago
  79. 49b7a3c [Issue:30] Support seek logic and add test case (#56) by 冉小龙 · 4 years, 9 months ago
  80. a615761 Check `golint`, `gofmt` and `go import` for project (#55) by 冉小龙 · 4 years, 9 months ago
  81. 8774688 [Issue:53] Fix concurrent map write (#54) by 冉小龙 · 4 years, 9 months ago
  82. 448387d Support partition consumer receive async and fix batch logic (#43) by 冉小龙 · 4 years, 9 months ago
  83. 670da09 Improve README.md and add CONTRIBUTING.md file (#51) by 冉小龙 · 4 years, 9 months ago
  84. a7c1a04 Fix the map of pendingReqs concurrent issue (#48) by 冉小龙 · 4 years, 9 months ago
  85. 7698eb9 Fix test killed with quit: ran too long (#50) by 冉小龙 · 4 years, 9 months ago
  86. dffa055 [Issue:45] Fix the logic of message router (#46) by 冉小龙 · 4 years, 9 months ago
  87. d049757 [issue:40]Fix producer send protocol error (#42) by 冉小龙 · 4 years, 9 months ago
  88. 61c5fe4 Ignore some files that are automatically generated in the project (#41) by 冉小龙 · 4 years, 9 months ago
  89. 9c79c0b Merge pull request #16 from wolfstudy/xiaolong/consumer-impl by Jia Zhai · 4 years, 9 months ago
  90. f525579 Merge master code and fix conflict by xiaolong.ran · 4 years, 9 months ago
  91. 987d2f0 Merge pull request #37 from wolfstudy/xiaolong/fix-zlib-compress by 冉小龙 · 4 years, 9 months ago
  92. f5c6ad9 fix ci error by xiaolong.ran · 4 years, 9 months ago
  93. 2e08a03 fix ci error by xiaolong.ran · 4 years, 9 months ago
  94. fa04e83 Merge pull request #38 from wolfstudy/xiaolong/fix-ci by Jia Zhai · 4 years, 9 months ago
  95. 1021c31 fix ci error by xiaolong.ran · 4 years, 9 months ago
  96. 588d8f0 Fix the openjdk-8-jre-headless can't download by xiaolong.ran · 4 years, 9 months ago
  97. 5227a57 [issue:34] Fix zlib compress Decompress logic by xiaolong.ran · 4 years, 9 months ago
  98. 4c90011 fix compression test error by xiaolong.ran · 4 years, 9 months ago
  99. 33a2899 fix ci error by xiaolong.ran · 4 years, 9 months ago
  100. d97be18 install jdk8 for docker image by xiaolong.ran · 4 years, 9 months ago