Google Git
Sign in
apache / pulsar-connectors / HEAD
  1. 33843ab Build connectors (#1) by Sijie Guo · 3 years, 6 months ago master
  2. e02495c [Bouncy Castle] include bc into pulsar-client fix docs (#8491) by Jia Zhai · 3 years, 6 months ago
  3. 54616d6 Upgrade solr version to 8.6.3 (#8328) by xiaolong ran · 3 years, 7 months ago
  4. da33628 Remove bouncy castle shaded module to avoid bring error of verifySingleJar (#7453) by Jia Zhai · 3 years, 7 months ago
  5. 97d28e7 Upgrade hdfs2 version to 2.8.5 (#8319) by xiaolong ran · 3 years, 7 months ago
  6. b81ab75 Fix JavaDoc issues. Spotted by IntelliJ (#8054) by Frank J Kelly · 3 years, 7 months ago
  7. a223dde [Security] Upgrade the snakeyaml verion to 1.26 (#7994) by 冉小龙 · 3 years, 8 months ago
  8. 164e0cc Fix security vulnerabilities of Pulsar (#7801) by 冉小龙 · 3 years, 9 months ago
  9. 0ddeb3d [pulsar-io-hdfs2] Add config to create subdirectory from current time (#7771) by Yunze Xu · 3 years, 9 months ago
  10. 369278e Fix various issues with batch source (#7716) by Boyang Jerry Peng · 3 years, 9 months ago
  11. 9f8edab #5922 - Update poms to use project.groupId instead of org.apache.pulsar where applicable (#7548) by Varghese Cottagiri · 3 years, 10 months ago
  12. 093aad3 Add limited module set profile to the pom files (#7541) by Ali Ahmed · 3 years, 10 months ago
  13. 8c41195 Avoid pulsar-client-api dependency on txn-common (#7511) by Matteo Merli · 3 years, 10 months ago
  14. ff5f01f [pulsar-server] minor: fix typo in service-config (#7248) by Rajan Dhabalia · 3 years, 11 months ago
  15. e39f463 Bumped version to 2.7.0-SNAPSHOT (#7233) by lipenghui · 3 years, 11 months ago
  16. bdcaa6a Extend PulsarIO to support Batch Sources. This pr implements PIP-65 (#7090) by Sanjeev Kulkarni · 4 years ago
  17. d657551 Split KafkaConnectSource into an abstract and impl (#6911) by Nathan Mills · 4 years ago
  18. 7a90a7c Added ability to add annotations to Connector Configs (#6983) by Sanjeev Kulkarni · 4 years ago
  19. 0905260 Fix break changes in namespace offload policy and RabbitMQ sink. (#7011) by lipenghui · 4 years ago
  20. 812b8f2 Add dynamodb streams source (#6874) by Jacob Burroughs · 4 years ago
  21. 0bc1a6c [Pulsar IO] Allow routing key per message to RabbitMQ sink connector (#5890) by Alex Rufo · 4 years ago
  22. 3b317dc [Issue 5215,4601,5215][pulsar-io] Add jdbc sinks: postgres, mariadb, clickhouse (#6835) by Sergii Zhevzhyk · 4 years ago
  23. 9c0523d Added ability to build consumers in functions and sources (#6954) by Sanjeev Kulkarni · 4 years ago
  24. 5d6ca6d Added ability for sources to publish messages on their own just like their function counterparts (#6941) by Sanjeev Kulkarni · 4 years ago
  25. 7a8b935 Fixing JDBC sink to handle null fields. Also added new unit tests (#6848) by Chris Bartholomew · 4 years ago
  26. 2ae5dcb [Pulsar IO][Issue 5633]Support avro schema for debezium connector (#6034) by guangning · 4 years ago
  27. 228104b Fix flaky test in InfluxDBSinkTest. (#6682) by Fangbin Sun · 4 years, 1 month ago
  28. aeabebf ISSUE-6514 Add support for influxdb2 in pulsar-influxdb-sink(#6514) (#6601) by Lin Yiming · 4 years, 1 month ago
  29. 3e28be0 Number of placeholder doesn't match number of arguments in logging (#6618) by Yijie Shen · 4 years, 1 month ago
  30. 72071d3 [minor]Reduce redundancy (#6611) by Yijie Shen · 4 years, 1 month ago
  31. e59771e [Maven Cleanup] Remove managed-ledger and zk-utils test-jar dependencies when possible (#6513) by Yijie Shen · 4 years, 2 months ago
  32. c5b46f5 Remove duplicated test libraries in POM dependencies (#6430) by Sergii Zhevzhyk · 4 years, 2 months ago
  33. d45f5cf [IO] updated aerospike-java-client version and fixed NPE (#6263) by Abhilash Mandaliya · 4 years, 3 months ago
  34. 8a828db [kinesis] Fix netty dependency conflict in Kinesis (#6199) by Addison Higham · 4 years, 3 months ago
  35. fb31bb3 Simplify templating in log messages (#6133) by Sergii Zhevzhyk · 4 years, 3 months ago
  36. 4a70370 [Issue 5690][pulsar-io] Make type name of Elasticsearch sink connector configurable. (#6028) by Yang Yang · 4 years, 3 months ago
  37. a7bc616 [Issue 5941][Pulsar IO]Upgrade debezium from v0.10.0-Final to v1.0.0-Final (#5972) by Guangning · 4 years, 4 months ago
  38. 1d30f08 [Github actions]Fixed unit test (#6004) by Guangning · 4 years, 4 months ago
  39. 681d29c Make unit tests to only use dynamically allocated ports (#5486) by Matteo Merli · 4 years, 4 months ago
  40. 2a5d8d9 Remove duplicated lombok annotations in the pulsar-io modules (#5911) by Sergii Zhevzhyk · 4 years, 4 months ago
  41. 4bee3f4 [Issue 5832][Pulsar IO]Fix npe of debezium delete event (#5876) by tuteng · 4 years, 5 months ago
  42. ab49fcc [Issue 5612] Use Reactivestreams client for Mongo Sink (#5635) by huangdx0726 · 4 years, 5 months ago
  43. a1d7663 Added catch for NoClassDefFoundError wherever there was a ClassNotFoundException (#5870) by Fred Eisele · 4 years, 5 months ago
  44. e39748e fix some typos (#5889) by Jia Zhai · 4 years, 5 months ago
  45. 03868ae [Issue 5827][Issue 5828][netty] Fixes for UDP protocol support in netty connector (#5829) by gbensa · 4 years, 5 months ago
  46. 88e8dbd Bump version to 2.6.0 (#5820) by Sijie Guo · 4 years, 5 months ago
  47. a87feea [pulsar-io] improve hbase sink performance (#5705) by YeChao Chen · 4 years, 6 months ago
  48. 64b385d [Issue 5474][pulsar-io-debezium] Support CDC Connector for MongoDB (#5590) by huangdx0726 · 4 years, 6 months ago
  49. 1414cfa [pulsar-io] hbase table should be closed properly (#5646) by YeChao Chen · 4 years, 6 months ago
  50. 6378539 [pulsar-io] hbase sink avoid flushing hbase table (#5629) by YeChao Chen · 4 years, 6 months ago
  51. a457004 [pulsar-io] [kafka-connect-adapter] KafkaSourceRecord - Initialize key property with Optional.empty() if keyBytes from SourceRecord is null (Optional property should never itself be null) (#5591) by Naveen Kumar · 4 years, 6 months ago
  52. 53ce338 [Issue 5561] Update Debezium version to 0.10.0.Final (#5573) by Naveen Kumar · 4 years, 6 months ago
  53. 91cec75 Use StandardCharsets.UTF_8 for converting String to bytes (#5372) by Like · 4 years, 6 months ago
  54. 9ee72b4 [zookeeper] bump zookeeper to version 3.5.6 (#5043) by Addison Higham · 4 years, 6 months ago
  55. 6223d65 Upgrade dependencies for security fixes (#5232) by Matteo Merli · 4 years, 6 months ago
  56. c2acc6a Use individual netty-* artifacts instead of netty-all (#3613) by Matteo Merli · 4 years, 6 months ago
  57. 8e96877 Multiple unit tests improvements (#5439) by Matteo Merli · 4 years, 7 months ago
  58. ae5f873 Add a source connector for MongoDB (#5316) by Bruno Bonnin · 4 years, 7 months ago
  59. 3e27f36 [kinesis-source] Improvements to kinesis-source (#5180) by Addison Higham · 4 years, 7 months ago
  60. 810edf9 Removed managed-ledger-shaded artifact (#4200) by Matteo Merli · 4 years, 7 months ago
  61. b86b5fa Pulsar-IO: Added Kinesis Source Connector (#3784) by David Kjerrumgaard · 4 years, 8 months ago
  62. 552c8a3 [pulsar-io-jdbc] not set action as insert (#4862) by Yi Tang · 4 years, 9 months ago
  63. 41b443c Test cleanup and simplification (#4799) by vzhikserg · 4 years, 10 months ago
  64. bd8bd17 Convert anonymous classes to lambda (#4703) by vzhikserg · 4 years, 10 months ago
  65. bf6aadc Upgrade to Mockito 2.x (#4671) by Matteo Merli · 4 years, 10 months ago
  66. 2254e22 [pulsar-io][jdbc sink]Support delete and update event for JDBC Sink (#4358) by tuteng · 4 years, 10 months ago
  67. a9bc084 Issue #4638 : Update Kafka connect-api to version 2.3.0 (#4650) by Guillaume Rosauro · 4 years, 10 months ago
  68. 9ec0b87 Bumped version to 2.5.0-SNAPSHOT (#4581) by lipenghui · 4 years, 11 months ago
  69. b8b3c12 [pulsar-io-elastic-search] NumberOfReplicas can be 0 (#4328) by Géraud Dugé de Bernonville · 5 years ago
  70. 7982472 Avoid to create map object for Flume source (#4369) by Like · 5 years ago
  71. f258da6 [pulsar-io-elastic-search] Change default document type for compliance with ES 7.x (#4322) by Géraud Dugé de Bernonville · 5 years ago
  72. 37e3247 Expose state to sources and sinks (#4364) by Sanjeev Kulkarni · 5 years ago
  73. a5584c6 [pulsar-io] Remove unused annotation (#4303) by Like · 5 years ago
  74. 6268681 [pulsar-io] hbase sink use BooleanSchema encode Boolean data (#4258) by wpl · 5 years ago
  75. 045f12a Add helper method to for IO connectors to use function secrets (#4222) by Boyang Jerry Peng · 5 years ago
  76. 1730576 Add the multi version schema support (#3876) by congbo · 5 years ago
  77. 29b3f2d Add sensitive annotations for Solr/RabbitMQ connector. (#4115) by Fangbin Sun · 5 years ago
  78. 03ea124 [pulsar-io] Add a Pulsar IO connector for InfluxDB sink (#4017) by Fangbin Sun · 5 years ago
  79. 5c27072 Specify the RabbitMQSink type as Bytes by default. (#4007) by Fangbin Sun · 5 years ago
  80. b3ac97a [Issue 3966] [pulsar-io] Specify the RedisSink type as Bytes by default (#3972) by Fangbin Sun · 5 years ago
  81. a80139d Add a Pulsar IO connector for RabbitMQ sink. (#3967) by Fangbin Sun · 5 years ago
  82. 115d190 Fix the path of redis-io yaml. (#3965) by Fangbin Sun · 5 years ago
  83. 9fecb60 [Issue 3884] [pulsar-io] Add a Pulsar IO connector for Solr sink (#3885) by Fangbin Sun · 5 years ago
  84. 895e6f2 Some minor improvement of RabbitMQ IO Source. (#3937) by Fangbin Sun · 5 years ago
  85. 6508e5e [Pulsar IO]: Add a source connector for debezium postgres (#3924) by Jia Zhai · 5 years ago
  86. 0b5c6d2 [Issue 3896] [pulsar-io] Fix NPE in ElasticSearchSink (#3899) by Fangbin Sun · 5 years ago
  87. eb27fd6 Added sensitive annotations (#3866) by Sanjeev Kulkarni · 5 years ago
  88. 1fea496 revise the schema default type not null (#3752) by congbo · 5 years ago
  89. f71f6f7 hide kafka-connecter details for easy use debezium connector (#3825) by Jia Zhai · 5 years ago
  90. 9142ce4 [pulsar-io] Add a Pulsar IO connector for Redis sink (#3700) by Fangbin Sun · 5 years ago
  91. e87758c fix elasticsearch in pom Consistent with other IOs (#3696) by wpl · 5 years ago
  92. fced81e Expose Secrets in Source/SinkContext (#3717) by Sanjeev Kulkarni · 5 years ago
  93. 1142d7a [Issue 3275][pulsar-io]Support source and sink of flume (#3597) by tuteng · 5 years ago
  94. 7c826ea [schema] Introduce `GenericSchema` interface (#3683) by Sijie Guo · 5 years ago
  95. 0ecd5eb Replace Junit with testng (#3675) by Like · 5 years ago
  96. 92a6891 [distribution] remove pulsar-io-debezium nar package (#3656) by Sijie Guo · 5 years ago
  97. 450a82a Bumped version to 2.4.0-SNAPSHOT (#3604) by Matteo Merli · 5 years ago
  98. 528dc3b Fixed RAT check to exclude Avro generated files (#3598) by Matteo Merli · 5 years ago
  99. 9302564 Add a Pulsar IO MongoDB (#3561) by Bruno Bonnin · 5 years ago
  100. ae7b99d Add a unit test for KafkaAbstractSink. (#3564) by Fangbin Sun · 5 years ago