Google Git
Sign in
apache / pulsar-adapters / HEAD
  1. afde244 [Flink] Allow to customize PulsarProducer (#3955) by Cristian · 5 years ago
  2. f4d6c82 Throw error explicitly on param value not in range (#3950) by Shivji Kumar Jha · 5 years ago
  3. e4bff46 Support Kafka's ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG in PulsarKafkaConsumer. (#3911) by Marvin Cai · 5 years ago
  4. e30c552 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
  5. 12f262a [flink] Allow to specify a custom Pulsar producer (#3894) by Cristian · 5 years ago
  6. 0a1f783 Add a wrapper around Kafka's ProducerInterceptor to support Kafka's ProducerConfig.INTERCEPTOR_CLASSES_CONFIG. #1090 (#3843) by Marvin Cai · 5 years ago
  7. c84409a Fix the loop of consumer poll, so the consumer can cache more than one record in signal poll. (#3852) by se7enkings · 5 years ago
  8. 459104b Support Kafka's ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG. (#3797) by Marvin Cai · 5 years ago
  9. 8f57563 Add support for Kafka's ProducerConfig.CONNECTIONS_MAX_IDLE_MS_CONFIG (#1090) (#3753) by Marvin Cai · 5 years ago
  10. 77106a0 Added support for "negative acks" in Java client (#3703) by Matteo Merli · 5 years ago
  11. af0449b add reset cousor to a specific publish time (#3622) by 冉小龙 · 5 years ago
  12. 486fef8 Replace Junit with testng (#3675) by Like · 5 years ago
  13. bd3b1d8 Bumped version to 2.4.0-SNAPSHOT (#3604) by Matteo Merli · 5 years ago
  14. f7e0ffb In PulsarKafkaProducer use flush() from pulsar API (#3549) by Matteo Merli · 5 years ago
  15. 7a0ba6f Added suppport for Kafka partitioner and explicit setting of partition on record (#3462) by Matteo Merli · 5 years ago
  16. 04a9840 Use topics in public/default namespaces for kafka ProducerExample and ConsumerExample (#3401) by wpl · 5 years ago
  17. 508d603 Use ConsumerConfig instead of ProducerConfig in PulsarKafkaConsumer (#3394) by Fangbin Sun · 5 years ago
  18. c140e56 Support to set subscriptionTopicsMode via properties. (#3395) by Fangbin Sun · 5 years ago
  19. 6ad7d87 After #3228, removed usages of deprecated client API (#3272) by Matteo Merli · 5 years ago
  20. dd3ba47 Adding config auto.offset.reset to PulsarKafkaConsumer (#3273) by Richard Yu · 5 years ago
  21. 7d20410 [flink-consumer-source] fix flink streaming connector examples to be consistent with batch examples (#3265) by wpl · 5 years ago
  22. 77b3bcd [Pulsar-Flink] Refactor Flink Batch Sink Examples (#3262) by Eren Avsarogullari · 5 years ago
  23. 5ec9479 Support multi-topic and pattern-topic for PulsarConsumerSource in pulsar (#3256) by penghui · 5 years ago
  24. f2f2319 [pulsar-flink] add streaming connectors as a Pulsar stream that serializes data in Avro format (#3231) by wpl · 5 years ago
  25. 075a2b0 [issues 3232] integrate flink-json to pulsar (#3234) by wpl · 5 years ago
  26. 0225b00 Make pulsar compile on windows (#3221) by ForwardXu · 5 years ago
  27. 20b0c49 Provide a flag to ignore Json format error in pulsar flink connector (#3210) by 浪尖 · 5 years ago
  28. 1e0bdeb fix up pulsar-flink and flink-consumer-source (#3212) by wpl · 5 years ago
  29. 6afa34d [pulsar-flink] Implements a batch program on Pulsar topic by writing Flink DataSet as Avro (#3205) by wpl · 5 years ago
  30. af92b06 [Pulsar-Flink] Add Batch Sink Scala Examples Documentation (#3190) by Eren Avsarogullari · 5 years ago
  31. 6701819 remove pulsar-client-schema (#3184) by Boyang Jerry Peng · 5 years ago
  32. e693b23 JSONSchema fails to serialise fields on objects that are nested in a collection (#2969) by chrismiller · 5 years ago
  33. 8eef807 [Pulsar-Flink] Add Scala Examples (#3071) by Eren Avsarogullari · 5 years ago
  34. 06eb4ef [Pulsar-Flink] Extends Validations (#3063) by Eren Avsarogullari · 5 years ago
  35. 9a4b868 [Pulsar-Flink] Add Batch Json Sink Support (#3046) by Eren Avsarogullari · 5 years ago
  36. cde0998 [Pulsar-Flink] Add Batch Csv Sink Support (#3039) by Eren Avsarogullari · 6 years ago
  37. e8bcfea cleaning up and improving function metrics (#2994) by Boyang Jerry Peng · 6 years ago
  38. 9ccff2a moving pulsar storm tests under tests (#3000) by Boyang Jerry Peng · 6 years ago
  39. 8ea0e72 Add Flink - Pulsar Batch Sink Support (#2979) by Eren Avsarogullari · 6 years ago
  40. f821674 Added pause and resume to Java client Consumer (#2961) by David Tinker · 6 years ago
  41. 1561b6d Remove guava usage in pulsar-storm (#2898) by Matteo Merli · 6 years ago
  42. 402e7d6 Issue #2890: Dependencies for using Pulsar in Storm topologies (#2893) by Sijie Guo · 6 years ago
  43. ec52181 Fixed shading of Netty (#2783) by Matteo Merli · 6 years ago
  44. be0ac31 Bumped version to 2.3.0-SNAPSHOT (#2765) by joefk · 6 years ago
  45. 9cba834 [clients][kafka] Fix topic name & race condition on kafka wrapper (#2746) by Sijie Guo · 6 years ago
  46. fd5dae0 Removed shading relocations for Circe-checksum and lz4 libraries (#2191) by Matteo Merli · 6 years ago
  47. 932504e Allow user to get topic from consumer message (#2007) (#2135) by Ivan Kelly · 6 years ago
  48. 705e294 Removed mentions to incubator-pulsar (#2620) by Matteo Merli · 6 years ago
  49. 88e6cfa Renamed 2.2.0-incubating-SNAPSHOT into 2.2.0-SNAPSHOT in poms (#2625) by Matteo Merli · 6 years ago
  50. dc9ec78 [documentation][example] Flink Source & Sink Connector (#2561) by Sijie Guo · 6 years ago
  51. 3011f7e [ecosystem] Flink pulsar source connector (#2555) by Sijie Guo · 6 years ago
  52. 5254016 Add pulsar flink sink connector (#2434) by Ali Ahmed · 6 years ago
  53. 2697dbb Make authentication parameters configurable on the pulsar-client-kafka (#2373) by ssunorz · 6 years ago
  54. fa7dc65 Rename Netty native libs to reflect shading prefix (#2192) by Matteo Merli · 6 years ago
  55. f485a38 fixing protobuf schema shading issue (#2168) by Boyang Jerry Peng · 6 years ago
  56. ea3f577 shading dependencies in pulsar client (#2120) by Boyang Jerry Peng · 6 years ago
  57. ec13137 adding a module that shades managed-ledge (#2034) by Boyang Jerry Peng · 6 years ago
  58. b5703a7 Bump Pulsar version to 2.2.0-incubating (#2027) by Sijie Guo · 6 years ago
  59. 0d6c439 Fixed shading of pulsar-client and pulsar-client-admin (#1974) by Matteo Merli · 6 years ago
  60. a4a83c6 adding avro schema (#1917) by Boyang Jerry Peng · 6 years ago
  61. f9bf031 Include Jackson modules in shaded jar as well (#1729) by Dave Rusek · 6 years ago
  62. 4e1b90a Bumped version to 2.1.0-incubating-SNAPSHOT (#1709) by Matteo Merli · 6 years ago
  63. 412d93c Make SchemaSerializationException an unchecked exception (#1693) by Matteo Merli · 6 years ago
  64. cfe2821 Introduced TypedMessageBuilder (#1683) by Matteo Merli · 6 years ago
  65. b15dd01 In pulsar admin Java API, unified persistent vs non-persistent into "topics()" (#1634) by Matteo Merli · 6 years ago
  66. 6e4d803 Fixed typo in ConsumerBuilder acknowledgmentGroupTime option (#1608) by Matteo Merli · 6 years ago
  67. de139ac Renamed "property" into "tenant" (#1578) by Matteo Merli · 6 years ago
  68. abb4b88 Converted and duplicated AdminApiTest to v2 topics (#1574) by Matteo Merli · 6 years ago
  69. 38157dd Provide unshaded pulsar-kafka-client (#1566) by Sijie Guo · 6 years ago
  70. ed5559c Converted to v2 topic names test related to ProducerConsumerBase (#1562) by Matteo Merli · 6 years ago
  71. 34f94f8 Added Kafka Source and Kafka Sink to Pulsar Connect (#1557) by Sanjeev Kulkarni · 6 years ago
  72. cbd416c Delayed acks impl (#1462) by Matteo Merli · 6 years ago
  73. ab67647 Extend Spark Streaming Receiver UT Coverage (#1448) by Eren Avsarogullari · 6 years ago
  74. b48f062 Refactored all unit tests to use new typed API with builders for configuration (#1320) by Matteo Merli · 6 years ago
  75. e68de23 Introduce a pulsar log4j2 appender (#1316) by Sijie Guo · 6 years ago
  76. 67dfc05 Converted main part of code to use builder APIs with typed interface (#1311) by Matteo Merli · 6 years ago
  77. 917ee58 Moved the bk-tests dependency to parent pom (#1308) by Matteo Merli · 6 years ago
  78. 9d7310d Add Type information to Pulsar client interface (#987) by Dave Rusek · 6 years ago
  79. d0ee8c2 Replace pulsar-checksum module with circe-checksum from BK (#1306) by Matteo Merli · 6 years ago
  80. b423554 Renamed DestinationName into TopicName (#1280) by Matteo Merli · 6 years ago
  81. 7f46081 add httpcore dep required by httpclient in hostname-verification (#1239) by Rajan Dhabalia · 6 years ago
  82. e770e23 Bumped master to 2.0.0-incubating-SNAPSHOT (#1226) by Matteo Merli · 6 years ago
  83. bff801f Add pluggable authorization mechanism (#1200) by Rajan Dhabalia · 6 years ago
  84. 82ea56a Allow to configure most client/producer/consumer options in Kafka API wrapper (#1207) by Matteo Merli · 6 years ago
  85. 0b1c8b7 Add hostname-verification at client tls connection (#1208) by Rajan Dhabalia · 6 years ago
  86. 7a445fe In Kafka consumer wrapper, group multiple messages when the app polls (#1115) by Matteo Merli · 6 years ago
  87. 07e725e Fix shading for Kafka wrapper lib (#1079) by Matteo Merli · 6 years ago
  88. 5606e7f Make sure nextTuple emits tuple with non-null values (#1000) by Rajan Dhabalia · 6 years ago
  89. 688a683 Bumped version to 1.22.0-incubating-SNAPSHOT (#925) by nkurihar · 6 years ago
  90. 833f44b Netty 4.1 (#689) by Matteo Merli · 6 years ago
  91. 4566806 Check whether the property exists at the beginning of `validateAdminAccessOnProperty` (#912) by Yuki Shiga · 6 years ago
  92. 586eaec Fail Pulsar storm spout/bolt init on consumer/producer creation failed (#905) by Rajan Dhabalia · 7 years ago
  93. 8d1b7a1 Fixed getting the position in PulsarKafkaConsumer when we don't have an offset yet (#900) by Matteo Merli · 7 years ago
  94. 61e92fb updating Storm version in Pulsar (#881) by Boyang Jerry Peng · 7 years ago
  95. 9a84b5f Make spark consumer-listener lambda Serializable (#866) by Rajan Dhabalia · 7 years ago
  96. 51e2ed9 Avoid interrupted exception in PulsarKafkaConsumer when shutting down (#852) by Matteo Merli · 7 years ago
  97. 9b492a2 Implement seekToBeginning()/end operations in Kafka consumer wrapper (#849) by Matteo Merli · 7 years ago
  98. 73993d9 Publish the shaded pulsar-client as the default dependency (#846) by Matteo Merli · 7 years ago
  99. a432ad1 Add PulsarClientImpl.getNumberOfPartitions() to avoid exposing PartitionedTopicMetadata (#842) by Matteo Merli · 7 years ago
  100. c10ad4e Correct Kafka wrapper producer blocking semantic and passing the producer config object (#833) by Matteo Merli · 7 years ago