Google Git
Sign in
apache/pulsar-connectors/HEAD
  1. c614f13 [improve][test] Add integration tests for the MongoDB source connector (#124) by David Kjerrumgaard · 2 weeks ago master
  2. 0989c11 [improve][test] Add integration tests for the Kinesis source connector (#123) by David Kjerrumgaard · 2 weeks ago
  3. 5cf71a6 [improve][test] KCA: re-enable broker tests (add buildtools + opentelemetry-sdk-testing) (#119) by David Kjerrumgaard · 3 weeks ago
  4. 9012157 [fix][test] Harden flaky timing assertions in FileListingTaskTest (#120) by David Kjerrumgaard · 3 weeks ago
  5. 07ec19f [improve][test] Add File source integration test (#115) by David Kjerrumgaard · 3 weeks ago
  6. c43eb7f [fix][io] File source: read zip entries so zip files emit records (#117) by David Kjerrumgaard · 3 weeks ago
  7. 69d6836 [improve][test] Add Netty source integration test and null-safe close() (#116) by David Kjerrumgaard · 3 weeks ago
  8. 81ae86a [fix][io] Fix Solr Sink KeyValue schema unwrapping for Debezium CDC (#26) by Praveen Kumar · 3 weeks ago
  9. 5d5847a [feat][mqtt] Support dynamic MQTT topic via topicProperty config (#34) by Dream95 · 3 weeks ago
  10. d254f50 [improve][io] Extend RMQ source with connection, queue and exchange options (#90) by Enrique Fernández · 3 weeks ago
  11. 03a4a30 feat(kinesis): add message key mode for Kinesis records (#35) by Rui Fu · 3 weeks ago
  12. c2c251a feat(kafka): copy Pulsar properties to Kafka headers and support idempotence (#36) by Rui Fu · 3 weeks ago
  13. 0a71167 [fix][io] Upgrade OpenMLDB client to 0.9.2 and add sink integration test (#105) by David Kjerrumgaard · 3 weeks ago
  14. 23a8961 [improve][test] Add HBase sink integration test (#104) by David Kjerrumgaard · 3 weeks ago
  15. 661efb5 [fix][io] Flush and sync before closing the HDFS text sink stream (#100) by David Kjerrumgaard · 3 weeks ago
  16. 52e3415 [improve][test] Bound container startup in all Testcontainers tests (#103) by David Kjerrumgaard · 3 weeks ago
  17. 89219f0 [fix][io] Pin opentelemetry-semconv to a version the HBase client can use (#102) by David Kjerrumgaard · 3 weeks ago
  18. 2094f3b [improve][test] Add NSQ source integration test (#95) by David Kjerrumgaard · 3 weeks ago
  19. d32fb93 [improve][test] Add HDFS3 sink integration test against MiniDFSCluster (#93) by David Kjerrumgaard · 3 weeks ago
  20. 090907a [improve][test] Add Aerospike sink integration test (#96) by David Kjerrumgaard · 3 weeks ago
  21. 28ef0cc [improve][ci] Shard the test job across three parallel runners (#92) by David Kjerrumgaard · 3 weeks ago
  22. 8528e36 [fix][test] Bound MqttSinkIntegrationTest container startup so it cannot hang CI (#91) by David Kjerrumgaard · 3 weeks ago
  23. 2ac8d84 [fix][test] Replace fixed sleeps with Awaitility polls in sink tests (#86) by David Kjerrumgaard · 3 weeks ago
  24. df04427 [fix][io] Interrupt Kafka Source instance thread on consumer fatal error to prevent deadlock (#88) by David Kjerrumgaard · 3 weeks ago
  25. 71bdfe6 [fix][io] jdbc: drain flush() iteratively to avoid StackOverflowError under sustained backlog (#39) by Darin Spivey · 3 weeks ago
  26. 518742a [fix][test] Wait for the public tenant before creating the test namespace (#84) by David Kjerrumgaard · 3 weeks ago
  27. adbdad6 [improve][test] Add DynamoDB source integration test (#77) by David Kjerrumgaard · 3 weeks ago
  28. c00efd9 [fix][io] Fix DynamoDB source client construction with a custom endpoint (#79) by David Kjerrumgaard · 3 weeks ago
  29. 10f9dae [fix][io] Prevent OOM in FileSource by bounding internal queues (#82) by David Kjerrumgaard · 3 weeks ago
  30. 799b907 [fix][io] Do not drop files when the work queue rejects an offer (#81) by David Kjerrumgaard · 3 weeks ago
  31. 02261c4 [improve][test] Add Kafka source and sink integration tests (#76) by David Kjerrumgaard · 3 weeks ago
  32. c736bd3 Set up default protection ruleset for default and release branches (#25) by The Apache Software Foundation · 3 weeks ago
  33. eb244a7 [fix][io] Fix skipped file listing loop runs in file connector (#14) by Philipp Dolif · 3 weeks ago
  34. c849b21 [improve][test] Add Solr sink integration test (#75) by David Kjerrumgaard · 3 weeks ago
  35. 47ed4c0 [improve][ci] Run the integrationTest source set in CI (#74) by David Kjerrumgaard · 3 weeks ago
  36. a76b3a3 [improve][test] Add InfluxDB v1 and v2 sink integration tests, deflake the v2 mock test (#73) by David Kjerrumgaard · 3 weeks ago
  37. 48aa4ae [doc][io] List the Debezium MariaDB source in the README connector table (#72) by David Kjerrumgaard · 3 weeks ago
  38. e0f878c [fix][test] Bound record reads in Debezium MySQL and Postgres tests (#71) by David Kjerrumgaard · 3 weeks ago
  39. 3ee99c4 [feat][io] Add Debezium MariaDB source connector (#69) by David Kjerrumgaard · 3 weeks ago
  40. 16bb0fd [improve][test] Add Debezium MongoDB source integration test (#58) by David Kjerrumgaard · 3 weeks ago
  41. 6377b96 [fix][io] Fix duplicate file offers and flaky tests in file connector (#41) by David Kjerrumgaard · 3 weeks ago
  42. 628934b [improve][io] Upgrade Debezium to 3.4.3.Final (#64) by David Kjerrumgaard · 3 weeks ago
  43. 5cecc7a [improve][test] Add MariaDB JDBC sink integration test (#59) by David Kjerrumgaard · 3 weeks ago
  44. 7814717 [fix][io] Fix loading offset issues in Kafka Adaptor (#31) by Jaroslav Kaspar · 4 weeks ago
  45. 05bc47f [fix][ci] Fix Tune Runner VM failure when no sd* block devices exist (#40) by David Kjerrumgaard · 4 weeks ago
  46. 54a505d [fix][ci] Update setup-gradle action to v6.2.0 to match ASF actions allowlist (#37) by David Kjerrumgaard · 4 weeks ago
  47. a46722b [fix][io] Upgrade ClickHouse jdbc client version to 0.9.8 (#33) by Jakub Knetl · 6 weeks ago
  48. f172336 [fix][io] Fix delayed acknowledgment for offset 0 in Kafka Connect Adapter (#24) by Malla Sandeep · 3 months ago
  49. 0537935 [feat][io] Add MQTT sink connector (#22) by Dream95 · 3 months ago
  50. b876095 [improve][build] Sync version catalog with apache/pulsar master (#20) by Lari Hotari · 3 months ago
  51. 6d09baa [fix][build] Fix the Jetty 9 bom override solution for Alluxio plugin (#19) by Lari Hotari · 3 months ago
  52. f0c0ea3 [fix][io] Fix acknowledgments not being sent when collapsePartitionedTopics=true in kafka-connect-adapter (#11) by Malla Sandeep · 3 months ago
  53. 31d67a2 [improve] Upgrade Hadoop to 3.5.0 (#18) by Lari Hotari · 4 months ago
  54. e689bc3 [fix][io] JDBC sink: prevent OOM from unbounded queue on connection failure (#9) by Harangozó Péter · 4 months ago
  55. c762d7e [improve][build] Improve the gradle build to use similar best practices as apache/pulsar build (#10) by Lari Hotari · 4 months ago
  56. 62b8773 Remove default_branch key and jira_options from .asf.yaml by Lari Hotari · 4 months ago
  57. 7a810f3 Add .asf.yaml for GitHub repository configuration by Matteo Merli · 4 months ago
  58. 32d9445 Add CI, integration test infrastructure, and testcontainer-based tests (#8) by Matteo Merli · 4 months ago
  59. 314b9de Initialize pulsar-connectors as standalone repository by Matteo Merli · 4 months ago
  60. 3d03f1e [cleanup] PIP-463: Migrate build system from Maven to Gradle (#25398) by Matteo Merli · 4 months ago
  61. 2c69483 [improve][build] Bump version to 4.3.0-SNAPSHOT in master, add branch-4.2 to protected branches (#25397) by Lari Hotari · 4 months ago
  62. fab5811 [fix][test] Fix thread leaks in multiple tests and KinesisSink (#25376) by Matteo Merli · 5 months ago
  63. 335f7cb [improve][io] Upgrade Debezium to 3.4.2 and Kafka Client/Connect to 4.1.1 (#25335) by Lari Hotari · 5 months ago
  64. 59eb757 [fix][io][kca] kafka headers silently dropped (#25325) by Enrique Fernández · 5 months ago
  65. ccd2f79 [fix][sec] Override msgpack-core to 0.9.11 to address CVE-2026-21452 (#25233) by guptas6est · 6 months ago
  66. 4c5d274 [feat][io] implement pip-297 for jdbc sinks (#25195) by Bäm · 6 months ago
  67. ce9e19e [improve][io] Set default connector class for debezium connectors (#25215) by jiangpengcheng · 6 months ago
  68. f23955f [fix][sec] Exclude org.lz4:lz4-java and standardize on at.yawk.lz4-java to remediate CVE-2025-12183 and CVE-2025-66566 (#25198) by guptas6est · 6 months ago
  69. 2830c37 [improve][misc] Upgrade to Alpine 3.23 (#25180) by Lari Hotari · 6 months ago
  70. 2afd8a1 [fix][sec] Bump org.apache.solr:solr-core from 9.8.0 to 9.10.1 in /pulsar-io/solr (#25175) by dependabot[bot] · 6 months ago
  71. ee5dd29 [improve][misc] Upgrade to Jetty 12.1.x (#25100) by Lari Hotari · 7 months ago
  72. 87f22c8 [improve][io] Add PUT method support to HttpSink (#25133) by Dream95 · 7 months ago
  73. 7ae957c [improve][io] Replace Qpid in tests with RabbitMQ in Testcontainers and upgrade RabbitMQ client version (#25085) by Lari Hotari · 8 months ago
  74. 2e2d118 [cleanup][io] Remove Pulsar IO Twitter connector (#25080) by Lari Hotari · 8 months ago
  75. 86908b1 [cleanup][io] Remove Pulsar IO Flume connector (#25079) by Lari Hotari · 8 months ago
  76. b6a9703 [fix][build] Remove Confluent and Restlet maven repositories from top level pom.xml (#24981) by Lari Hotari · 9 months ago
  77. f1bdeb2 [fix][test] Fixed nondeterministic ordering in MongoSourceTest.testWriteBadMessage (#24835) by Lucas Eby · 9 months ago
  78. e3c3dad [fix][test] Fixed ResponseBody Check in Test Helper (#24872) by Lucas Eby · 9 months ago
  79. 1a3e063 [fix][sec] Update Hbase version to 2.6.3-hadoop3 and exclude Avro from hbase-client to remediate CVEs (#24953) by guptas6est · 9 months ago
  80. 6a032b0 [fix][sec] Override kafka-clients in kinesis-kpl-shaded to remediate CVE-2024-31141 and CVE-2025-27817 (#24935) by guptas6est · 9 months ago
  81. 3d908d0 [improve][io] Use try-with-resources for some locations (#24900) by AROP · 9 months ago
  82. 690c416 [fix][test] Fixed Nondeterministic Assertions in KafkaAbstractSinkTest (#24877) by Lucas Eby · 9 months ago
  83. 551299a [improve] Upgrade Alpine base image to 3.22 version (#24840) by Lari Hotari · 10 months ago
  84. e8b47b8 [fix][test] Fixed nondeterministic JSON ordering in multiple tests (#24821) by Lucas Eby · 10 months ago
  85. fe45d39 [fix][client] Exclude io.prometheus:simpleclient_caffeine from client-side dependencies (#24761) by Lari Hotari · 11 months ago
  86. 6c069e4 [fix][io] Improve Kafka Connect source offset flushing logic (#24654) by Harangozó Péter · 11 months ago
  87. 3d56edb [improve][io] Upgrade to Debezium 3.2.2 (#24712) by Enrique Fernández · 11 months ago
  88. ac4dd5d [fix][build] Set project version to 4.2.0-SNAPSHOT (#24690) by Cong Zhao · 11 months ago
  89. c9de431 [improve][client] PIP-420: Supports users implement external schemas (#24488) by ran · 11 months ago
  90. 7005512 [improve][io] Support specifying Kinesis KPL native binary path with 1.0 version specific path (#24669) by Lari Hotari · 11 months ago
  91. 9fb8ad2 [improve][io] Upgrade AWS SDK v1 & v2, Kinesis KPL and KPC versions (#24661) by Lari Hotari · 11 months ago
  92. d772a60 [improve][broker] Upgrade avro version to 1.12.0 (#24617) by Hang Chen · 12 months ago
  93. 32f471f [improve][io] support array schema for JDBC postgres connector (#24549) by Rui Fu · 12 months ago
  94. 3bd4b37 [fix][sec] Upgrade Kafka connector and clients version to 3.9.1 to address CVE-2025-27818 (#24564) by Lari Hotari · 1 year ago
  95. c32a75a [improve][io] Add support for the complete KinesisProducerConfiguration in KinesisSinkConfig (#24489) by Malla Sandeep · 1 year ago
  96. 5f57d33 [fix][io] Fix Kinesis checkpoint mechanism to prevent data duplication (#24534) by Baodi Shi · 1 year ago
  97. c912d96 [fix][misc] Upgrade dependencies to fix critical security vulnerabilities (#24532) by Penghui Li · 1 year, 1 month ago
  98. c1bafc0 [fix][io] Fix data loss issue in Kinesis source connector (#24501) by Baodi Shi · 1 year, 1 month ago
  99. 8c970e4 [improve][ci] Fixes #23079: Checkstyle checks applied to all test (#24492) by Praveen Kumar · 1 year, 1 month ago
  100. 8ebf12a [fix][io] Make record properties configurable for kinesis source (#24495) by Baodi Shi · 1 year, 1 month ago