Google Git
Sign in
apache / pulsar-adapters / HEAD
  1. 079f3b5 When trigger kafka producer callback, don't wrap the exception if it's null (#832) by Matteo Merli · 7 years ago
  2. 105f958 Bumped version to 1.21.0-incubating-SNAPSHOT (#815) by Rajan Dhabalia · 7 years ago
  3. eae6ef1 Kafka client Java API wrapper (#761) by Matteo Merli · 7 years ago
  4. f8f4430 Don't run Javadoc and Swagger builds on regular mvn package (#670) by Matteo Merli · 7 years ago
  5. 662803f Bumped version to 1.20.0-incubating-SNAPSHOT (#609) by Matteo Merli · 7 years ago
  6. cfac304 Changed version to 1.19-incubating-SNAPSHOT (#527) by Matteo Merli · 7 years ago
  7. dcc872a Updated maven groupId from com.yahoo.pulsar to org.apache.pulsar (#525) by Matteo Merli · 7 years ago
  8. 6cc358f Renamed java package names in scripts and documentation (#524) by Matteo Merli · 7 years ago
  9. e02a9f3 Renamed Java packages from com.yahoo.pulsar to org.apache.pulsar (#524) by Matteo Merli · 7 years ago
  10. 97d04bb Updates headers with ASF source files header (#519) by Rajan Dhabalia · 7 years ago
  11. 659e150 Bump version to 1.19-SNAPSHOT by Matteo Merli · 7 years ago
  12. 24e0ff9 Pulsar release v1.18 by rdhabalia · 7 years ago
  13. 6c3ac7c Fixed pulsar-spark pom version (#330) by Matteo Merli · 7 years ago
  14. b857b71 Added spark streaming custom receiver for pulsar (#296) by Yuki Shiga · 7 years ago
  15. 782382e Bump version to 1.18-SNAPSHOT by rdhabalia · 7 years ago
  16. 0e3e7c8 Pulsar release v1.17 by rdhabalia · 7 years ago
  17. 3814151 Fixed circular dependency in slf4j loggers for pulsar-storm unit tests (#264) by Matteo Merli · 7 years ago
  18. 90635c1 Avoid printing unit test info logs by default for pulsar-storm (#259) by Matteo Merli · 7 years ago
  19. 1a06f67 Bump version to 1.17-SNAPSHOT by rdhabalia · 7 years ago
  20. 5630890 Pulsar release v1.16 by rdhabalia · 7 years ago
  21. 50299da Updating ning async-http-client to use Netty4 based implementation (#97) by sschepens · 8 years ago
  22. 42b44ab Bump version to 1.16-SNAPSHOT by Matteo Merli · 8 years ago
  23. 5745ed2 Pulsar release v1.15 by Matteo Merli · 8 years ago
  24. 0c9975f Set version to 1.15-SNAPSHOT by Matteo Merli · 8 years ago
  25. 2431a7f Initial import by Matteo Merli · 8 years ago
  26. eb53acd Allow building Apache Pulsar on JDK15+ - upgrade Maven Assembly Plugin (#8360) by Enrico Olivelli · 3 years, 8 months ago
  27. fef3c37 Remove bouncy castle shaded module to avoid bring error of verifySingleJar (#7453) by Jia Zhai · 3 years, 8 months ago
  28. d339a1e [pulsar-admin] allow to get ledger metadata along with topic stats-internal (#8180) by Rajan Dhabalia · 3 years, 9 months ago
  29. 5113431 Fix JavaDoc issues. Spotted by IntelliJ (#8054) by Frank J Kelly · 3 years, 9 months ago
  30. a4598c6 Support acknowledging a list of messages (#7688) by feynmanlin · 3 years, 10 months ago
  31. 1a2be2f Avoid dependency on Apache HTTP client for TLS hostname verifier (#7612) (#7664) by Matteo Merli · 3 years, 11 months ago
  32. 5aa6f7a #5922 - Update poms to use project.groupId instead of org.apache.pulsar where applicable (#7548) by Varghese Cottagiri · 4 years ago
  33. f66b7e3 Bumped version to 2.7.0-SNAPSHOT (#7233) by lipenghui · 4 years ago
  34. 1eb1d52 Fix apache rat check (#7225) by lipenghui · 4 years ago
  35. d1b3cb7 Fix kafka_0_9 Consumer partition topic throw error (#7179) by liudezhi · 4 years ago
  36. 34c72aa [Issue 4803][client] return null if the message value/data is not set by producer (#6379) by Neng Lu · 4 years, 1 month ago
  37. 52e6463 [pulsar-storm] Fix: Authentication is failing with storm adapter (#6782) by Rajan Dhabalia · 4 years, 1 month ago
  38. 800a8ff Make messageReceiveTimeoutMs in the PulsarConsumerSource configurable (#6783) by luceneReader · 4 years, 2 months ago
  39. d3bcfbb Update the status of pulsar-flink connector (#6657) by Sijie Guo · 4 years, 2 months ago
  40. 0f41100 Support Consumers Set Custom Retry Delay (#6449) by liudezhi · 4 years, 2 months ago
  41. a9027cb Number of placeholder doesn't match number of arguments in logging (#6618) by Yijie Shen · 4 years, 3 months ago
  42. e8e959b ISSUE-5934: Support read/write properties from/to Message in flink pulsar consumer/producer (#5955) by duli559 · 4 years, 3 months ago
  43. a61b649 [Maven Cleanup] Remove managed-ledger and zk-utils test-jar dependencies when possible (#6513) by Yijie Shen · 4 years, 3 months ago
  44. 186f4ff Independent schema is set for each consumer generated by topic (#6356) by congbo · 4 years, 3 months ago
  45. ba8c7cd [Flink-Connector]Get PulsarClient from cache should always return an open instance (#6436) by Yijie Shen · 4 years, 4 months ago
  46. 4f4e90f [Pulsar-Client] Stop shade snappy-java in pulsar-client-shaded (#6375) by Yijie Shen · 4 years, 4 months ago
  47. e617abf [pulsar-kafka] support block-producer on queue-full with sendTimeOut configuration (#6139) by Rajan Dhabalia · 4 years, 4 months ago
  48. aa465c4 [Issue 6024][pulsar_storm] PulsarSpout emit to multiple streams (#6039) by David Willcox · 4 years, 5 months ago
  49. d8c2e00 Simplify templating in log messages (#6133) by Sergii Zhevzhyk · 4 years, 5 months ago
  50. a593e13 [build] Skip javadoc task for pulsar-client-kafka-compact modules (#5836) by Sijie Guo · 4 years, 5 months ago
  51. 7cc617e Upgrade Avro to 1.9.1 (#5938) by Masahiro Sakamoto · 4 years, 5 months ago
  52. 748bb4e [pulsar-flink]Cache Pulsar client to make it shared among tasks in a process (#5900) by Yijie Shen · 4 years, 6 months ago
  53. 5fe4e17 Added catch for NoClassDefFoundError wherever there was a ClassNotFoundException (#5870) by Fred Eisele · 4 years, 6 months ago
  54. ed7a31a Bump version to 2.6.0 (#5820) by Sijie Guo · 4 years, 6 months ago
  55. 9815cff [PIP-38] Support batch receive in java client. (#4621) by lipenghui · 4 years, 7 months ago
  56. 96d4431 Use StandardCharsets.UTF_8 for converting String to bytes (#5372) by Like · 4 years, 7 months ago
  57. 1cbcc29 expose new message with different schema (#5517) by Yi Tang · 4 years, 8 months ago
  58. abfa4fa [Test] Migrate deprecated Matchers to ArgumentMatchers (#5423) by Like · 4 years, 8 months ago
  59. c95ef94 Use individual netty-* artifacts instead of netty-all (#3613) by Matteo Merli · 4 years, 8 months ago
  60. a9aac0a Removed managed-ledger-shaded artifact (#4200) by Matteo Merli · 4 years, 9 months ago
  61. 4ed632d Fix client backoff (#5261) by Boyang Jerry Peng · 4 years, 9 months ago
  62. 2a7ba2c Fixed spark receiver to account for all the consumer config options (#5152) by Matteo Merli · 4 years, 9 months ago
  63. 3b2b12a Make client keepalive interval configurable on pulsar-client-kafka (#5131) by Rikuo Takahama · 4 years, 10 months ago
  64. 26a2c5f expose getLastMessageId method in ConsumerImpl (#4911) by Jia Zhai · 4 years, 10 months ago
  65. 7f1cef8 Add support of pulsar-kafka-adapter for kafka-0.8 api (#4797) by Rajan Dhabalia · 4 years, 11 months ago
  66. cb9f7ed Add support of pulsar-kafka-adapter for kafka-0.9 api (#4886) by Xiaobing Fang · 4 years, 11 months ago
  67. 295e23a Perform Checkstyle analysis in the pulsar-flink module (#4832) by vzhikserg · 4 years, 11 months ago
  68. 573b1a4 Test cleanup and simplification (#4799) by vzhikserg · 5 years ago
  69. 3625496 Fix：PulsarKafkaProducer is not thread safe (#4745) by Xiaobing Fang · 5 years ago
  70. 4508568 Upgrade to Mockito 2.x (#4671) by Matteo Merli · 5 years ago
  71. 232f425 Cleanup in the pulsar-log4j-appender project (#4681) by vzhikserg · 5 years ago
  72. cad0116 Support Pulsar schema for pulsar kafka client wrapper (#4534) by tuteng · 5 years ago
  73. bb4a1c1 Issue #4638 : Update Kafka connect-api to version 2.3.0 (#4650) by Guillaume Rosauro · 5 years ago
  74. cadc53c Bumped version to 2.5.0-SNAPSHOT (#4581) by lipenghui · 5 years ago
  75. 6734eac Introduce batch message container framework and support key based batching container (#4435) by lipenghui · 5 years ago
  76. 9c7842f [pulsar-kafka] Fix KafkaProducerInterceptorWrapper handles LongSerializer (#4549) by Sijie Guo · 5 years ago
  77. 6f5bf89 [pulsar-storm] add option to pass consumerConfiguration to PulsarSpout (#4494) by Rajan Dhabalia · 5 years ago
  78. abc0318 [pulsar-storm] pulsar-bolt: add option to pass producer-configuration (#4495) by Rajan Dhabalia · 5 years ago
  79. 8a08664 [Issue 4379] [Java Client] Build auth from class and params in PulsarClientImpl (#4381) by Shivji Kumar Jha · 5 years ago
  80. 699b3c5 [pulsar-storm] Upgrade storm version to 2.0.0 (#4486) by Rajan Dhabalia · 5 years ago
  81. fd2ed42 Add missed serialization schema argument for PulsarOutputFormat constructor (#4373) by Like · 5 years ago
  82. 2c2d434 Configure static PulsarByteBufAllocator to handle OOM errors (#4196) by Matteo Merli · 5 years ago
  83. c524aa1 [pulsar-storm] support reader for pulsar-spout (#4236) by Rajan Dhabalia · 5 years ago
  84. be96b83 [Issue 4283][flink] construct auth when building pulsar source (#4284) by Shivji Kumar Jha · 5 years ago
  85. d0ce73b [pulsar-storm] add more metrics to troubleshoot spout throughput (#4280) by Rajan Dhabalia · 5 years ago
  86. 94212e1 [pulsar-storm] allow option to configure queue size of pulsar-spout-consumer (#4239) by Rajan Dhabalia · 5 years ago
  87. a78c542 [issue 3954] [flink] Use (client/consumer/producer) pojo to pass config to pulsar client (#4232) by Shivji Kumar Jha · 5 years ago
  88. e45df3d [pulsar-storm] provide auto-unsubscribe option in pulsar-spout (#4238) by Rajan Dhabalia · 5 years ago
  89. 735239d [pulsar-spark] upgrade SparkStreamingPulsarReceiver.java use pulsar-client and add spark example (#4143) by wpl · 5 years ago
  90. 97d5c87 [pulsar-flink] Add subscription initial position (#4129) by lipenghui · 5 years ago
  91. 97157e2 [pulsar-storm] Fix NPE while emitting next tuple (#3991) by Rajan Dhabalia · 5 years ago
  92. 4c3d018 [Issue-2122] [pulsar-client] Adding configuration for backoff strategy (#3848) by Richard Yu · 5 years ago
  93. 98590cf issue#3939 : Allow client authentication from pulsar-flink package (#3949) by Shivji Kumar Jha · 5 years ago
  94. b84dbfe [Flink] Allow to customize PulsarProducer (#3955) by Cristian · 5 years ago
  95. fa326f4 Throw error explicitly on param value not in range (#3950) by Shivji Kumar Jha · 5 years ago
  96. 030b8db Support Kafka's ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG in PulsarKafkaConsumer. (#3911) by Marvin Cai · 5 years ago
  97. 52a73b8 Support Kafka's ConsumerConfig.MAX_POLL_RECORDS_CONFIG to config max number of message will return in a single poll. (#3887) by Marvin Cai · 5 years ago
  98. 9337c21 [flink] Allow to specify a custom Pulsar producer (#3894) by Cristian · 5 years ago
  99. 0806405 Add a wrapper around Kafka's ProducerInterceptor to support Kafka's ProducerConfig.INTERCEPTOR_CLASSES_CONFIG. #1090 (#3843) by Marvin Cai · 5 years ago
  100. 553a519 Fix the loop of consumer poll, so the consumer can cache more than one record in signal poll. (#3852) by se7enkings · 5 years ago