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