Google Git
Sign in
apache / pulsar-adapters / HEAD
  1. 5aeddbb Add Strom adapter back after removing from Apache Storm repo (#55) by Rajan Dhabalia · 6 months ago master
  2. 145ac23 feat: Support consumer replicateSubscriptionState config (#52) by tison · 9 months ago
  3. 477fe3c Add OWASP dep checker (#33) by Andrey Yegorov · 1 year ago
  4. ab537c1 Strom adapter moved to Apache Storm community (#47) by Andrey Yegorov · 1 year, 1 month ago
  5. 9c1f67c Update Flink Pulsar connector link (#43) by tison · 1 year, 2 months ago
  6. f7f4a9b Remove dependency on org.apache.pulsar.functions.utils.FunctionCommon in kafka-compat (#44) by Christophe Bornet · 1 year, 2 months ago
  7. 45b0d45 Use an assembly descriptor to configure permissions (#42) by Christophe Bornet · 1 year, 2 months ago
  8. 93f74c1 Only send notifications to commits@ mailing list (#41) by Zike Yang · 1 year, 2 months ago
  9. 357fa3b [pulsar-kafka] Fixed blockIfQueueFull config (#36) by hailin0 · 1 year, 2 months ago
  10. 1d8ee48 [improve] Kafka adaptor - Handle partition topic. (#37) by changqing · 1 year, 2 months ago
  11. 2392bfe enable Reproducible Builds (#39) by Hervé Boutemy · 1 year, 2 months ago
  12. 3350cb5 Update to Pulsar 2.11.0 (#40) by Christophe Bornet · 1 year, 2 months ago
  13. 0adca97 Auto update partition for pulsar kafka producer (#28) by Rajan Dhabalia · 2 years, 1 month ago
  14. b363865 Import dependencies from Pulsar's parent POM (#35) by Christophe Bornet · 2 years, 2 months ago
  15. 195d125 Removing Flink in favor of https://github.com/apache/flink/tree/master/flink-connectors/flink-connector-pulsar (#34) by Andrey Yegorov · 2 years, 3 months ago
  16. 4ccaf7b Upgrade Log4J2 to 2.17.1 (#32) by Lari Hotari · 2 years, 4 months ago
  17. ef29667 Upgrade Log4J2 to 2.15.0 to mitigate CVE-2021-44228 (#30) by Lari Hotari · 2 years, 5 months ago
  18. feaa450 [pulsar-kafka] Support encryption for pulsar-kafka producer/consumer (#26) by Rajan Dhabalia · 2 years, 10 months ago
  19. df8fc19 Add build instructions to README (#24) by Enrico Olivelli · 2 years, 11 months ago
  20. 9801c43 Fixed integration tests (#22) by Andrey Yegorov · 2 years, 11 months ago
  21. 74c0dd8 [Build] Add GitHub Actions build for pulsar-adapters (#19) by Lari Hotari · 2 years, 11 months ago
  22. 238f8a9 Add guava dependency to modules that need it (#21) by Lari Hotari · 2 years, 11 months ago
  23. 16b1c15 [Build] Fix leakage of buildtools dependency to all libraries (#20) by Lari Hotari · 2 years, 11 months ago
  24. d87c3ff Pulsar Log4j2 Appender: allow configuration of the client (#17) by Lari Hotari · 2 years, 11 months ago
  25. 019454f [Build] Upgrade Pulsar dependency to 2.8.0 and fix build errors (#18) by Lari Hotari · 2 years, 11 months ago
  26. 0372947 [pulsar-kafka] add auto update partition support to producer/consumer (#13) by Rajan Dhabalia · 3 years ago
  27. e3f72a4 Feature: Run Kafka streams app with Pulsar (#10) by Andrey Yegorov · 3 years, 1 month ago
  28. f82e51f build pulsar-adaptors with pulsar-2.8-snapshot (#9) by Andrey Yegorov · 3 years, 1 month ago
  29. 80d75af Move examples and tests from main repo here (#3) by Sijie Guo · 3 years, 6 months ago
  30. 789b152 Fix checkstyle issue on pulsar-spark module (#2) by Sijie Guo · 3 years, 6 months ago
  31. 615c576 Build pulsar-adapters (#1) by Sijie Guo · 3 years, 6 months ago
  32. 3099d62 Initialize pulsar-adapters project by Sijie Guo · 4 years, 1 month ago
  33. 0f2a340 Allow building Apache Pulsar on JDK15+ - upgrade Maven Assembly Plugin (#8360) by Enrico Olivelli · 3 years, 7 months ago
  34. aaf3b6b Remove bouncy castle shaded module to avoid bring error of verifySingleJar (#7453) by Jia Zhai · 3 years, 7 months ago
  35. b031fee [pulsar-admin] allow to get ledger metadata along with topic stats-internal (#8180) by Rajan Dhabalia · 3 years, 7 months ago
  36. 3893e32 Fix JavaDoc issues. Spotted by IntelliJ (#8054) by Frank J Kelly · 3 years, 7 months ago
  37. 22e1978 Support acknowledging a list of messages (#7688) by feynmanlin · 3 years, 9 months ago
  38. 397ee00 Avoid dependency on Apache HTTP client for TLS hostname verifier (#7612) (#7664) by Matteo Merli · 3 years, 10 months ago
  39. ba071ba #5922 - Update poms to use project.groupId instead of org.apache.pulsar where applicable (#7548) by Varghese Cottagiri · 3 years, 10 months ago
  40. 3e15a9d Bumped version to 2.7.0-SNAPSHOT (#7233) by lipenghui · 4 years ago
  41. b663331 Fix apache rat check (#7225) by lipenghui · 4 years ago
  42. b67247b Fix kafka_0_9 Consumer partition topic throw error (#7179) by liudezhi · 4 years ago
  43. 1c40b74 [Issue 4803][client] return null if the message value/data is not set by producer (#6379) by Neng Lu · 4 years ago
  44. 3234e14 [pulsar-storm] Fix: Authentication is failing with storm adapter (#6782) by Rajan Dhabalia · 4 years ago
  45. 8786f5e Make messageReceiveTimeoutMs in the PulsarConsumerSource configurable (#6783) by luceneReader · 4 years, 1 month ago
  46. 2e84a72 Update the status of pulsar-flink connector (#6657) by Sijie Guo · 4 years, 1 month ago
  47. 657701a Support Consumers Set Custom Retry Delay (#6449) by liudezhi · 4 years, 1 month ago
  48. c03310d Number of placeholder doesn't match number of arguments in logging (#6618) by Yijie Shen · 4 years, 2 months ago
  49. 72a71f2 ISSUE-5934: Support read/write properties from/to Message in flink pulsar consumer/producer (#5955) by duli559 · 4 years, 2 months ago
  50. d8c623b [Maven Cleanup] Remove managed-ledger and zk-utils test-jar dependencies when possible (#6513) by Yijie Shen · 4 years, 2 months ago
  51. 2d17195 Independent schema is set for each consumer generated by topic (#6356) by congbo · 4 years, 2 months ago
  52. 0a8864a [Flink-Connector]Get PulsarClient from cache should always return an open instance (#6436) by Yijie Shen · 4 years, 2 months ago
  53. 3bd10d0 [Pulsar-Client] Stop shade snappy-java in pulsar-client-shaded (#6375) by Yijie Shen · 4 years, 3 months ago
  54. 40b305c [pulsar-kafka] support block-producer on queue-full with sendTimeOut configuration (#6139) by Rajan Dhabalia · 4 years, 3 months ago
  55. 0144e86 [Issue 6024][pulsar_storm] PulsarSpout emit to multiple streams (#6039) by David Willcox · 4 years, 3 months ago
  56. e671435 Simplify templating in log messages (#6133) by Sergii Zhevzhyk · 4 years, 4 months ago
  57. 560d9a2 [build] Skip javadoc task for pulsar-client-kafka-compact modules (#5836) by Sijie Guo · 4 years, 4 months ago
  58. 69dd087 Upgrade Avro to 1.9.1 (#5938) by Masahiro Sakamoto · 4 years, 4 months ago
  59. 4f2e108 [pulsar-flink]Cache Pulsar client to make it shared among tasks in a process (#5900) by Yijie Shen · 4 years, 4 months ago
  60. e9803b5 Added catch for NoClassDefFoundError wherever there was a ClassNotFoundException (#5870) by Fred Eisele · 4 years, 5 months ago
  61. 119b740 Bump version to 2.6.0 (#5820) by Sijie Guo · 4 years, 5 months ago
  62. 27e21b0 [PIP-38] Support batch receive in java client. (#4621) by lipenghui · 4 years, 6 months ago
  63. bba8876 Use StandardCharsets.UTF_8 for converting String to bytes (#5372) by Like · 4 years, 6 months ago
  64. e3605d5 expose new message with different schema (#5517) by Yi Tang · 4 years, 6 months ago
  65. 5416b00 [Test] Migrate deprecated Matchers to ArgumentMatchers (#5423) by Like · 4 years, 6 months ago
  66. c1137a1 Use individual netty-* artifacts instead of netty-all (#3613) by Matteo Merli · 4 years, 7 months ago
  67. a53ff30 Removed managed-ledger-shaded artifact (#4200) by Matteo Merli · 4 years, 8 months ago
  68. f36c0e4 Fix client backoff (#5261) by Boyang Jerry Peng · 4 years, 8 months ago
  69. 512af8f Fixed spark receiver to account for all the consumer config options (#5152) by Matteo Merli · 4 years, 8 months ago
  70. 2fe6085 Make client keepalive interval configurable on pulsar-client-kafka (#5131) by Rikuo Takahama · 4 years, 8 months ago
  71. b0b1ff8 expose getLastMessageId method in ConsumerImpl (#4911) by Jia Zhai · 4 years, 9 months ago
  72. d4506c9 Add support of pulsar-kafka-adapter for kafka-0.8 api (#4797) by Rajan Dhabalia · 4 years, 9 months ago
  73. 9d39961 Add support of pulsar-kafka-adapter for kafka-0.9 api (#4886) by Xiaobing Fang · 4 years, 9 months ago
  74. 632cf39 Perform Checkstyle analysis in the pulsar-flink module (#4832) by vzhikserg · 4 years, 10 months ago
  75. 4f621df Test cleanup and simplification (#4799) by vzhikserg · 4 years, 10 months ago
  76. 27bae1b Fix：PulsarKafkaProducer is not thread safe (#4745) by Xiaobing Fang · 4 years, 10 months ago
  77. 7abf1a4 Upgrade to Mockito 2.x (#4671) by Matteo Merli · 4 years, 10 months ago
  78. c0bb58d Cleanup in the pulsar-log4j-appender project (#4681) by vzhikserg · 4 years, 10 months ago
  79. cba7598 Support Pulsar schema for pulsar kafka client wrapper (#4534) by tuteng · 4 years, 10 months ago
  80. 0b61db5 Issue #4638 : Update Kafka connect-api to version 2.3.0 (#4650) by Guillaume Rosauro · 4 years, 10 months ago
  81. 7a6723e Bumped version to 2.5.0-SNAPSHOT (#4581) by lipenghui · 4 years, 11 months ago
  82. b491857 Introduce batch message container framework and support key based batching container (#4435) by lipenghui · 5 years ago
  83. 513940a [pulsar-kafka] Fix KafkaProducerInterceptorWrapper handles LongSerializer (#4549) by Sijie Guo · 5 years ago
  84. 7e8c0ea [pulsar-storm] add option to pass consumerConfiguration to PulsarSpout (#4494) by Rajan Dhabalia · 5 years ago
  85. 4fe84f7 [pulsar-storm] pulsar-bolt: add option to pass producer-configuration (#4495) by Rajan Dhabalia · 5 years ago
  86. 0916b2a [Issue 4379] [Java Client] Build auth from class and params in PulsarClientImpl (#4381) by Shivji Kumar Jha · 5 years ago
  87. aaefa50 [pulsar-storm] Upgrade storm version to 2.0.0 (#4486) by Rajan Dhabalia · 5 years ago
  88. ee21ad8 Add missed serialization schema argument for PulsarOutputFormat constructor (#4373) by Like · 5 years ago
  89. e52b037 Configure static PulsarByteBufAllocator to handle OOM errors (#4196) by Matteo Merli · 5 years ago
  90. edab4ee [pulsar-storm] support reader for pulsar-spout (#4236) by Rajan Dhabalia · 5 years ago
  91. a0a5598 [Issue 4283][flink] construct auth when building pulsar source (#4284) by Shivji Kumar Jha · 5 years ago
  92. 10a26e1 [pulsar-storm] add more metrics to troubleshoot spout throughput (#4280) by Rajan Dhabalia · 5 years ago
  93. 0fd0e1b [pulsar-storm] allow option to configure queue size of pulsar-spout-consumer (#4239) by Rajan Dhabalia · 5 years ago
  94. a76e620 [issue 3954] [flink] Use (client/consumer/producer) pojo to pass config to pulsar client (#4232) by Shivji Kumar Jha · 5 years ago
  95. fc413e1 [pulsar-storm] provide auto-unsubscribe option in pulsar-spout (#4238) by Rajan Dhabalia · 5 years ago
  96. 80a6187 [pulsar-spark] upgrade SparkStreamingPulsarReceiver.java use pulsar-client and add spark example (#4143) by wpl · 5 years ago
  97. 8fc17cf [pulsar-flink] Add subscription initial position (#4129) by lipenghui · 5 years ago
  98. 6b2be1a [pulsar-storm] Fix NPE while emitting next tuple (#3991) by Rajan Dhabalia · 5 years ago
  99. 3dc4ddf [Issue-2122] [pulsar-client] Adding configuration for backoff strategy (#3848) by Richard Yu · 5 years ago
  100. 394ae52 issue#3939 : Allow client authentication from pulsar-flink package (#3949) by Shivji Kumar Jha · 5 years ago