Google Git
Sign in
apache/pulsar-connectors/HEAD
  1. f172336 [fix][io] Fix delayed acknowledgment for offset 0 in Kafka Connect Adapter (#24) by Malla Sandeep · 3 weeks ago master
  2. 0537935 [feat][io] Add MQTT sink connector (#22) by Dream95 · 3 weeks ago
  3. b876095 [improve][build] Sync version catalog with apache/pulsar master (#20) by Lari Hotari · 5 weeks ago
  4. 6d09baa [fix][build] Fix the Jetty 9 bom override solution for Alluxio plugin (#19) by Lari Hotari · 5 weeks ago
  5. f0c0ea3 [fix][io] Fix acknowledgments not being sent when collapsePartitionedTopics=true in kafka-connect-adapter (#11) by Malla Sandeep · 6 weeks ago
  6. 31d67a2 [improve] Upgrade Hadoop to 3.5.0 (#18) by Lari Hotari · 7 weeks ago
  7. e689bc3 [fix][io] JDBC sink: prevent OOM from unbounded queue on connection failure (#9) by Harangozó Péter · 8 weeks ago
  8. c762d7e [improve][build] Improve the gradle build to use similar best practices as apache/pulsar build (#10) by Lari Hotari · 8 weeks ago
  9. 62b8773 Remove default_branch key and jira_options from .asf.yaml by Lari Hotari · 9 weeks ago
  10. 7a810f3 Add .asf.yaml for GitHub repository configuration by Matteo Merli · 9 weeks ago
  11. 32d9445 Add CI, integration test infrastructure, and testcontainer-based tests (#8) by Matteo Merli · 9 weeks ago
  12. 314b9de Initialize pulsar-connectors as standalone repository by Matteo Merli · 9 weeks ago
  13. 3d03f1e [cleanup] PIP-463: Migrate build system from Maven to Gradle (#25398) by Matteo Merli · 9 weeks ago
  14. 2c69483 [improve][build] Bump version to 4.3.0-SNAPSHOT in master, add branch-4.2 to protected branches (#25397) by Lari Hotari · 10 weeks ago
  15. fab5811 [fix][test] Fix thread leaks in multiple tests and KinesisSink (#25376) by Matteo Merli · 2 months ago
  16. 335f7cb [improve][io] Upgrade Debezium to 3.4.2 and Kafka Client/Connect to 4.1.1 (#25335) by Lari Hotari · 2 months ago
  17. 59eb757 [fix][io][kca] kafka headers silently dropped (#25325) by Enrique Fernández · 3 months ago
  18. ccd2f79 [fix][sec] Override msgpack-core to 0.9.11 to address CVE-2026-21452 (#25233) by guptas6est · 4 months ago
  19. 4c5d274 [feat][io] implement pip-297 for jdbc sinks (#25195) by Bäm · 4 months ago
  20. ce9e19e [improve][io] Set default connector class for debezium connectors (#25215) by jiangpengcheng · 4 months ago
  21. 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 · 4 months ago
  22. 2830c37 [improve][misc] Upgrade to Alpine 3.23 (#25180) by Lari Hotari · 4 months ago
  23. 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] · 4 months ago
  24. ee5dd29 [improve][misc] Upgrade to Jetty 12.1.x (#25100) by Lari Hotari · 5 months ago
  25. 87f22c8 [improve][io] Add PUT method support to HttpSink (#25133) by Dream95 · 5 months ago
  26. 7ae957c [improve][io] Replace Qpid in tests with RabbitMQ in Testcontainers and upgrade RabbitMQ client version (#25085) by Lari Hotari · 6 months ago
  27. 2e2d118 [cleanup][io] Remove Pulsar IO Twitter connector (#25080) by Lari Hotari · 6 months ago
  28. 86908b1 [cleanup][io] Remove Pulsar IO Flume connector (#25079) by Lari Hotari · 6 months ago
  29. b6a9703 [fix][build] Remove Confluent and Restlet maven repositories from top level pom.xml (#24981) by Lari Hotari · 7 months ago
  30. f1bdeb2 [fix][test] Fixed nondeterministic ordering in MongoSourceTest.testWriteBadMessage (#24835) by Lucas Eby · 7 months ago
  31. e3c3dad [fix][test] Fixed ResponseBody Check in Test Helper (#24872) by Lucas Eby · 7 months ago
  32. 1a3e063 [fix][sec] Update Hbase version to 2.6.3-hadoop3 and exclude Avro from hbase-client to remediate CVEs (#24953) by guptas6est · 7 months ago
  33. 6a032b0 [fix][sec] Override kafka-clients in kinesis-kpl-shaded to remediate CVE-2024-31141 and CVE-2025-27817 (#24935) by guptas6est · 7 months ago
  34. 3d908d0 [improve][io] Use try-with-resources for some locations (#24900) by AROP · 7 months ago
  35. 690c416 [fix][test] Fixed Nondeterministic Assertions in KafkaAbstractSinkTest (#24877) by Lucas Eby · 7 months ago
  36. 551299a [improve] Upgrade Alpine base image to 3.22 version (#24840) by Lari Hotari · 8 months ago
  37. e8b47b8 [fix][test] Fixed nondeterministic JSON ordering in multiple tests (#24821) by Lucas Eby · 8 months ago
  38. fe45d39 [fix][client] Exclude io.prometheus:simpleclient_caffeine from client-side dependencies (#24761) by Lari Hotari · 8 months ago
  39. 6c069e4 [fix][io] Improve Kafka Connect source offset flushing logic (#24654) by Harangozó Péter · 9 months ago
  40. 3d56edb [improve][io] Upgrade to Debezium 3.2.2 (#24712) by Enrique Fernández · 9 months ago
  41. ac4dd5d [fix][build] Set project version to 4.2.0-SNAPSHOT (#24690) by Cong Zhao · 9 months ago
  42. c9de431 [improve][client] PIP-420: Supports users implement external schemas (#24488) by ran · 9 months ago
  43. 7005512 [improve][io] Support specifying Kinesis KPL native binary path with 1.0 version specific path (#24669) by Lari Hotari · 9 months ago
  44. 9fb8ad2 [improve][io] Upgrade AWS SDK v1 & v2, Kinesis KPL and KPC versions (#24661) by Lari Hotari · 9 months ago
  45. d772a60 [improve][broker] Upgrade avro version to 1.12.0 (#24617) by Hang Chen · 10 months ago
  46. 32f471f [improve][io] support array schema for JDBC postgres connector (#24549) by Rui Fu · 10 months ago
  47. 3bd4b37 [fix][sec] Upgrade Kafka connector and clients version to 3.9.1 to address CVE-2025-27818 (#24564) by Lari Hotari · 10 months ago
  48. c32a75a [improve][io] Add support for the complete KinesisProducerConfiguration in KinesisSinkConfig (#24489) by Malla Sandeep · 10 months ago
  49. 5f57d33 [fix][io] Fix Kinesis checkpoint mechanism to prevent data duplication (#24534) by Baodi Shi · 10 months ago
  50. c912d96 [fix][misc] Upgrade dependencies to fix critical security vulnerabilities (#24532) by Penghui Li · 11 months ago
  51. c1bafc0 [fix][io] Fix data loss issue in Kinesis source connector (#24501) by Baodi Shi · 11 months ago
  52. 8c970e4 [improve][ci] Fixes #23079: Checkstyle checks applied to all test (#24492) by Praveen Kumar · 11 months ago
  53. 8ebf12a [fix][io] Make record properties configurable for kinesis source (#24495) by Baodi Shi · 11 months ago
  54. 690f1a9 [improve][build] replace org.apache.commons.lang to org.apache.commons.lang3 (#24473) by StevenLuMT · 11 months ago
  55. 4000314 [fix][io] Acknowledge RabbitMQ message after processing the message successfully (#24354) by Lari Hotari · 1 year ago
  56. 2655ab3 [fix][io] Fix kinesis avro bytes handling (#24316) by Christophe Bornet · 1 year ago
  57. 31475eb [improve][io] Add configuration parameter for disabling aggregation for Kinesis Producers (#24289) by Malla Sandeep · 1 year, 1 month ago
  58. b3e9847 [improve][io][kca] support fully-qualified topic names in source records (#24248) by Enrique Fernández · 1 year, 1 month ago
  59. f02da94 [improve][misc] Migrate from multiple nullness annotation libraries to JSpecify annotations (#24239) by Lari Hotari · 1 year, 1 month ago
  60. 4b86970 [improve][io] support kafka connect transforms and predicates (#24221) by Enrique Fernández · 1 year, 1 month ago
  61. 28a1f68 [improve][io] Upgrade Kafka client and compatible Confluent platform version (#24201) by Lari Hotari · 1 year, 1 month ago
  62. 5e8ab3e [improve][build] Build apachepulsar/pulsar-io-kinesis-sink-kinesis_producer with Alpine 3.21 (#24180) by Lari Hotari · 1 year, 2 months ago
  63. 3c2a8f8 [fix][io] Fix KinesisSink json flattening for AVRO's SchemaType.BYTES (#24132) by Christophe Bornet · 1 year, 2 months ago
  64. cbdcd05 [improve][io] Enhance Kafka connector logging with focused bootstrap server information (#24128) by Rui Fu · 1 year, 2 months ago
  65. 6e26175 [improve][io] Remove sleep when sourceTask.poll of kafka return null (#24124) by Baodi Shi · 1 year, 2 months ago
  66. 346f1e5 [fix][io] Fix pulsar-io:pom not found (#23979) by Zixuan Liu · 1 year, 4 months ago
  67. 41c5d34 [fix] Bump org.eclipse.jetty:jetty-server from 10.0.22 to 10.0.24 in /pulsar-io/solr (#23973) by dependabot[bot] · 1 year, 4 months ago
  68. 172004a [fix] Bump org.apache.solr:solr-core from 8.11.3 to 9.8.0 in /pulsar-io/solr (#23899) by dependabot[bot] · 1 year, 4 months ago
  69. 85a1e6d [fix] Fix issues with Pulsar Alpine docker image stability: remove glibc-compat (#23762) by Lari Hotari · 1 year, 5 months ago
  70. fab4237 [improve][io] Bump io.lettuce:lettuce-core from 5.0.2.RELEASE to 6.5.1.RELEASE in /pulsar-io/redis (#23685) by dependabot[bot] · 1 year, 6 months ago
  71. e484c57 [fix][sec] Replace bcprov-jdk15on dependency with bcprov-jdk18-on (#23532) by Lari Hotari · 1 year, 7 months ago
  72. 9d4893a [fix][build] Set project version to 4.1.0-SNAPSHOT (#23442) by Lari Hotari · 1 year, 8 months ago
  73. 1dd6477 [fix][sec] Drop hdfs2 support, Upgrade hadoop3 to 3.4.0 and dnsjava to 3.6.2 to address CVE-2024-25638 (#23411) by Lari Hotari · 1 year, 8 months ago
  74. f352804 [improve] Upgrade opensearch sink to client 2.16 and tests to use server 2.16.0 (#23312) by Andrey Yegorov · 1 year, 9 months ago
  75. a7489b8 [improve][build] Bump version to 4.0.0-SNAPSHOT (#23146) by Lari Hotari · 1 year, 10 months ago
  76. e4b2021 [fix][build] Remove unnecessary Oracle maven repository from pom.xml (#23132) by Lari Hotari · 1 year, 10 months ago
  77. 8a18f47 [improve][io] The JDBC connector supports JSON substructure schema (#23043) by Baodi Shi · 1 year, 10 months ago
  78. fe19563 [fix][ci] Fix OWASP Dependency Check download by using NVD API key (#22999) by Lari Hotari · 1 year, 11 months ago
  79. ed7fd12 [improve][client] Deprecate `MessageIdUtils.getOffset` and `MessageIdUtils.getMessageId` (#22747) by Zike Yang · 2 years ago
  80. f9f4329 [improve][build] Remove invalid relativePath definitions in pom.xml files (#22741) by Lari Hotari · 2 years ago
  81. 6b8fd51 [improve][build] Bump version to 3.4.0-SNAPSHOT (#22700) by Cong Zhao · 2 years, 1 month ago
  82. 68b1212 Revert "[fix][sec] Upgrade Debezium oracle connector version to avoid… (#22668) by Lari Hotari · 2 years, 1 month ago
  83. 65f9077 [fix][io] Fix es index creation (#22654) by Zixuan Liu · 2 years, 1 month ago
  84. 668980b [fix][sec] Upgrade Debezium oracle connector version to avoid CVE-2023-4586 (#22641) by Nikhil Erigila · 2 years, 1 month ago
  85. 459c05a [improve][misc] Upgrade slf4j to 2.0.13 (#22391) by Zixuan Liu · 2 years, 1 month ago
  86. 81a7804 [fix][io] CompressionEnabled didn't work on elasticsearch sink (#22565) by Baodi Shi · 2 years, 1 month ago
  87. b2998aa [fix][io] Kafka Source connector maybe stuck (#22511) by Baodi Shi · 2 years, 2 months ago
  88. c23f694 [improve][io]: Add validation for JDBC sink not supporting primitive schema (#22376) by Baodi Shi · 2 years, 2 months ago
  89. 8d4946d [improve][cli] PIP-343: Use picocli instead of jcommander in pulsar-function (#22331) by Zixuan Liu · 2 years, 2 months ago
  90. 04b2cff [improve][cli] PIP-343: Use picocli instead of jcommander in bin/pulsar (#22288) by Zixuan Liu · 2 years, 2 months ago
  91. 297531b [improve][pip] PIP-324: Alpine image (#22054) by Matteo Merli · 2 years, 3 months ago
  92. 7df6fca [feat][io] AzureDataExplorer/Kusto Sink for Pulsar (#22006) by Abhishek Saharn · 2 years, 4 months ago
  93. a259871 [fix] Bump org.apache.solr:solr-core from 8.11.1 to 8.11.3 in /pulsar-io/solr (#22047) by dependabot[bot] · 2 years, 4 months ago
  94. 25126d9 [improve][build] Bump version to 3.3.0-SNAPSHOT (#21818) by Lari Hotari · 2 years, 5 months ago
  95. d806f47 [improve][ci] Exclude jose4j to avoid CVE-2023-31582 (#21791) by Jiwei Guo · 2 years, 5 months ago
  96. 7c758a8 [fix][test] Close the resource after the test. (#21732) by Jiwei Guo · 2 years, 6 months ago
  97. ac50a48 [improve][misc] Pin Netty version in pulsar-io/alluxio (#21728) by Lari Hotari · 2 years, 6 months ago
  98. c31e665 [fix][build] Upgrade alluxio version to 2.9.3 to fix CVE-2023-38889 (#21715) by Jiwei Guo · 2 years, 6 months ago
  99. a60b963 [fix][sec] Exclude avro from hadoop-client (#21719) by Xiangying Meng · 2 years, 6 months ago
  100. c5c3ea5 [improve][io] Make connectors load sensitive fields from secrets (#21675) by jiangpengcheng · 2 years, 6 months ago