Google Git
Sign in
apache / flink-connector-kafka / HEAD
  1. 00c9c8c [FLINK-35228][Connectors/Kafka] Fix: DynamicKafkaSource does not read re-added topic for the same cluster (#97) by Ignas Daukšas · 11 days ago main
  2. 369e7be [FLINK-35038] Bump `org.yaml:snakeyaml` to `2.2` (#93) by Ufuk Celebi · 4 weeks ago
  3. 1c39e3b [FLINK-35008] Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 (#87) by dependabot[bot] · 4 weeks ago
  4. c47abb3 [FLINK-34961] Use dedicated CI name for Kafka connector to differentiate it in infra-reports by Sergey Nuyanzin · 4 weeks ago
  5. 2f5e3cf [hotfix] Add Java 21 as JDK to test for Flink 1.19.0 weekly runs by Martijn Visser · 4 weeks ago
  6. 897001d [FLINK-35007] Add support for Flink 1.19 (#90) by Martijn Visser · 4 weeks ago
  7. 15f2662 [hotfix] Add JDK21 for 1.19-SNAPSHOT by Martijn Visser · 3 months ago
  8. 489dd7b [hotfix] Test against Flink 1.19-SNAPSHOT for `main` and Weekly builds by Martijn Visser · 3 months ago
  9. 2606a82 [FLINK-34193] Remove usage of Flink-Shaded Jackson and Snakeyaml in flink-connector-kafka by Jiabao Sun · 3 months ago
  10. b8328ab [FLINK-34192] Update to be compatible with updated SinkV2 interfaces by Jiabao Sun · 3 months ago
  11. cfb275b [FLINK-34244] Update Confluent Platform to 7.4.4. This closes #81 by Martijn Visser · 3 months ago
  12. 6d0ffcd [hotfix] Update shortcode in Kafka Datastream documentation so that the download links appear by Martijn Visser · 3 months ago
  13. ab356b4 [hotfix] Make the upsert-kafka artifacts point to the regular kafka artifacts in the documentation by Martijn Visser · 3 months ago
  14. abf4563 [hotfix] Update copyright year to 2024 (#82) by Hang Ruan · 3 months ago
  15. 624f0a1 [hotfix] Update copyright year to 2024 by Martijn Visser · 4 months ago
  16. a468c2b [hotfix] Add missing JDK17 test for 1.18 against v3.1 by Martijn Visser · 4 months ago
  17. 68ac980 [hotfix] Remove weekly test against 1.19-SNAPSHOT since that's currently broken and tracked under FLINK-34193 by Martijn Visser · 4 months ago
  18. fd7b46c [release] Update weekly CI to check against new release branch `v3.1` by Martijn Visser · 4 months ago
  19. 4f30099 [FLINK-32417] Add DynamicKafkaSource documentation for setter methods, metrics, and config options. This closes #80 by Mason Chen · 4 months ago
  20. 6f06f15 [FLINK-34154] Bump org.apache.zookeeper:zookeeper from 3.5.9 to 3.7.2. This closes #72 by dependabot[bot] · 4 months ago
  21. 8d53189 [FLINK-33329] Bump org.apache.commons:commons-compress from 1.22 to 1.25.0. This closes #73 by dependabot[bot] · 4 months ago
  22. d3bda90 [hotfix] Synchronize CI pipeline setup. This closes #78 by Martijn Visser · 4 months ago
  23. cdfa328 [FLINK-32416] Fix flaky tests by ensuring test utilities produce records with consistency and cleanup notify no more splits to ensure it is sent. This closes #79 by Mason Chen · 4 months ago
  24. eaeb781 [FLINK-32416] initial implementation of DynamicKafkaSource with bounded/unbounded support and unit/integration tests by mas-chen · 9 months ago
  25. 825052f [FLINK-33361][connectors/kafka] Add Java 17 compatibility to Flink Kafka connector by Sergey Nuyanzin · 5 months ago
  26. c38a040 [FLINK-33559] Externalize Kafka Python connector code by pvary · 5 months ago
  27. 979791c [hotfix] refer to sql_connector_download_table shortcode in the docs to adhere to new connector versioning format by mas-chen · 6 months ago
  28. b732ce3 [hotfix] Partially revert 40da49e73b956b1a6fa0c1351b695b520c91919e and don't test against Flink 1.19-SNAPSHOT yet by Martijn Visser · 7 months ago
  29. 40da49e [hotfix] Test connector against Flink 1.18.0 and Flink 1.19-SNAPSHOT by Martijn Visser · 7 months ago
  30. 54e3b70 [FLINK-28303] Allow LATEST_OFFSET marker when restoring from old checkpoints by Tzu-Li (Gordon) Tai · 7 months ago
  31. 946df1e [FLINK-28303] Support LatestOffsetsInitializer to avoid latest-offset strategy lose data by tanjialiang · 8 months ago
  32. 37cbb83 [FLINK-30400][build] Stop bundling flink-connector-base. This closes #50 by Hang Ruan · 7 months ago
  33. 398054a [hotfix] Update CI strategy. This closes #61 by MartijnVisser · 7 months ago
  34. c829d7a [FLINK-33238][Formats/Avro] Upgrade used AVRO version to 1.11.3. This closes #59 by MartijnVisser · 7 months ago
  35. bd260f1 [FLINK-33191][Connector/Kafka] Make the `testKafkaValueDeserializationSchemaWrapper` test use `flink-shaded-jackson` since it tests `flink-shaded-jackson` ObjectNodes. by Martijn Visser · 7 months ago
  36. e9d3089 [FLINK-33191][Connector/Kafka] Remove dependency on Flink Shaded by Martijn Visser · 7 months ago
  37. 26ab532 [FLINK-33234][Connector/Kafka] Exclude bundled Guava versions from Kafka AVRO serializer and Kafka Schema Registry Client by Martijn Visser · 7 months ago
  38. 89343bb [FLINK-33234][Connector/Kafka] Bump Guava to 32.1.2-jre by dependabot[bot] · 7 months ago
  39. b0f15f2 [FLINK-33231] [source] Properly evict offsetsToCommit cache on checkpoint complete if no offsets exist by Tzu-Li (Gordon) Tai · 7 months ago
  40. 73f761f [FLINK-33149][Connector/Kafka] Bump snappy-java from 1.1.8.3 to 1.1.10.5 by dependabot[bot] · 11 months ago
  41. b09928d [FLINK-33219][connector/kafka] Add new archunit violation messages introduced by FLINK-31804. This closes #56 by Qingsheng Ren · 7 months ago
  42. d89a082 [FLINK-29398] Provide rack ID to KafkaSource to take advantage of Rack Awareness by Ethan Gouty · 1 year, 3 months ago
  43. 4c03d60 [hotfix][docs] Optimize the Security part in docs by Hang Ruan · 8 months ago
  44. 27a5465 [FLINK-28758] Fix stop-with-savepoint for FlinkKafkaConsumer by Piotr Nowojski · 8 months ago
  45. 818d1fd [FLINK-33017] Remove dependency on shaded guava by Alex Sorokoumov · 8 months ago
  46. d6525c1 [FLINK-31208][Connectors/Kafka] KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits) by Hongshun Wang · 1 year ago
  47. 79ae2d7 [FLINK-32591][Connectors/Kafka] Update document of Kafka Source: Enable Dynamic Partition Discovery by Default in Kafka Source by Hongshun Wang · 10 months ago
  48. 811716c [FLINK-32020] Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288 by Hongshun Wang · 1 year ago
  49. 9109722 [FLINK-31408] Add support for EOS delivery-guarantee in upsert-kafka by Alex Sorokoumov · 1 year, 2 months ago
  50. 21d3b10 [FLINK-32453] Ambiguous assertThat call after upgrade to Flink 1.18 by Tzu-Li (Gordon) Tai · 10 months ago
  51. 97dbfca [FLINK-32455] Copy over TypeSerializerUpgradeTestBase due to breaking change in Flink 1.18 by Tzu-Li (Gordon) Tai · 10 months ago
  52. 14d8462 [FLINK-32021][kafka] Improve the java docs of SpecifiedOffsetsInitializer and TimestampOffsetsInitializer by Hongshun Wang · 10 months ago
  53. ad62c13 [FLINK-32019][Connector/Kafka] EARLIEST offset strategy for partitions discoveried later based on FLIP-288 by Hongshun Wang · 1 year ago
  54. c1e3527 [FLINK-32462] Pin the used shaded version of Guava and Jackson in the Kafka connector by Martijn Visser · 11 months ago
  55. 910fc5a [FLINK-31747] Remove Confluent Avro formats from externalized Kafka connector repo by Tzu-Li (Gordon) Tai · 11 months ago
  56. 27e2bd3 [FLINK-32289][docs] Fix incorrect metadata column type in examples by yuxiqian · 11 months ago
  57. 2244688 [FLINK-32172][kafka] KafkaExampleUtils incorrect check of the minimum number of parameters (#30) by Weijie Guo · 12 months ago
  58. fc526a8 Update version to 3.1-SNAPSHOT by Tzu-Li (Gordon) Tai · 1 year, 1 month ago
  59. c9f8aa9 [hotfix] [flink-connector-kafka] Simplify ProducerRecord instantiation w.r.t. headers by Tzu-Li (Gordon) Tai · 1 year, 1 month ago
  60. a778563 [FLINK-31049] [flink-connector-kafka] Add support for Kafka record headers to KafkaSink by Alex Gout · 1 year, 2 months ago
  61. 96780b9 [FLINK-31747] remove debezium json for now by mas-chen · 1 year, 1 month ago
  62. d762d01 [FLINK-30859] Externalize confluent avro related code by mas-chen · 1 year, 2 months ago
  63. 0d30880 [hotfix] Update copyright NOTICE year to 2023 by Robert Metzger · 1 year, 2 months ago
  64. 453592b [hotfix] Sort NOTICE dependencies in alphabetical order by Martijn Visser · 1 year, 2 months ago
  65. f1a078c [FLINK-31485][Confluent Avro] Change packaging of Schema Registry so that by default everything is included. by Martijn Visser · 1 year, 2 months ago
  66. 6f905fb [FLINK-31085][formats] Add schema option to confluent registry avro formats by Fruzsina Nagy · 1 year, 2 months ago
  67. efad9b5 [FLINK-31348][Docs] Fix unclosed shortcodes (/tabs) in the docs, that causes issues with Hugo version 0.111.0 and higher. This closes #22113 by David Moravek · 1 year, 2 months ago
  68. 35ac273 Update version to 1.18-SNAPSHOT by Leonard Xu · 1 year, 3 months ago
  69. ad930a4 [FLINK-29638][connectors][filesystems][formats] Update Jackson-BOM to 2.13.4.2 by Sergey Nuyanzin · 1 year, 7 months ago
  70. d9a80bd [FLINK-28405][Connector/Kafka] Update Confluent Platform images used for testing to v7.2.2. This closes #20170 by MartijnVisser · 1 year, 7 months ago
  71. 85e5ca6 [FLINK-29468][connectors][filesystems][formats] Update Jackson-BOM to 2.13.4. by Sergey Nuyanzin · 1 year, 7 months ago
  72. a81eba6 [FLINK-29513][Connector/Kafka] Update Kafka to version 3.2.3 which contains certain security fixes by Martijn Visser · 1 year, 7 months ago
  73. 9975414 [FLINK-25868][build] Disable japicmp in packaging/e2e modules by Chesnay Schepler · 2 years, 3 months ago
  74. 4abce4b Update version to 1.17-SNAPSHOT by huangxingbo · 1 year, 8 months ago
  75. 54d3c6c [FLINK-24718] Update Avro dependency to 1.11.1 by Ryan Skraba · 1 year, 8 months ago
  76. e71024c [FLINK-28676] Update copyright year to 2014-2022 in NOTICE files by Benchao Li · 1 year, 10 months ago
  77. 077210b [FLINK-28060][kafka] Bump Kafka to 3.2.1 by Chesnay Schepler · 1 year, 9 months ago
  78. f34906d [FLINK-28621][core] Add central Jackson mapper factory methods by Chesnay Schepler · 1 year, 10 months ago
  79. a6b822a [FLINK-28621][formats] Initialize mappers in open() by Chesnay Schepler · 1 year, 10 months ago
  80. a31ac02 [FLINK-28807] Honor schema lifecycle by Chesnay Schepler · 1 year, 10 months ago
  81. 4a141f0 [FLINK-28634][json] Deprecate JsonNodeDeserializationSchema by Chesnay Schepler · 1 year, 10 months ago
  82. bbc81ba [FLINK-28634][json] Add simple JsonSerDeSchema by Chesnay Schepler · 1 year, 10 months ago
  83. 95f315e [FLINK-28222][json] Add flink-sql-json module by Chesnay Schepler · 1 year, 11 months ago
  84. 43854ab [FLINK-28060][Connector/Kafka] Updated Kafka Clients to 3.1.1 to resolve the issue where Flink is unable to commit its offset back to Kafka in case of Kafka Broker becoming unavailable. This should be resolved when the broker comes back up, but due to KAFKA-13563 that doesn't work. Since that fix has only become available with Kafka Clients 3.1.1, this commit updates the Kafka Clients dependency from 2.8.4 to 3.1.1. by Martijn Visser · 1 year, 11 months ago
  85. dd6c275 [FLINK-27442][Formats][Avro Confluent] Add Confluent repo to module flink-sql-avro-confluent-registry by MartijnVisser · 2 years ago
  86. 0ff1cd0 [hotfix][json][tests] Fix location of services directory by Chesnay Schepler · 2 years ago
  87. 2371b92 [FLINK-27352][json][tests] Migrate flink-json to JUnit5 by BiGsuw · 2 years ago
  88. 3507b28 [FLINK-24721][build] Remove unnecessary relativePath to parent by Chesnay Schepler · 2 years, 1 month ago
  89. a56a132 [FLINK-26011][json][test] add ArchUnit tests for the test code by Jing Ge · 2 years, 1 month ago
  90. 1b0ab39 [FLINK-26011][avro-confluent-registry][test] add ArchUnit tests for the test code by Jing Ge · 2 years, 1 month ago
  91. 239b361 [FLINK-26961][connectors][filesystems][formats] Update Jackson Databind and Annotations to 2.13.2.2, Jackson Dataformat to 2.13.2, Jackson Core to 2.13.2 and Jackson-BOM to 2.13.2.20220328. This closes #19303 by Sergey Nuyanzin · 2 years, 1 month ago
  92. 9beeb21 [FLINK-26736][tests] Migrate flink-avro-confluent-registry to JUnit5 by Ryan Skraba · 2 years, 2 months ago
  93. 4b1ca3e Update version to 1.16-SNAPSHOT by Yun Gao · 2 years, 2 months ago
  94. d2b7bb3 [FLINK-24745][format][json] Improve the metadata tests and documentation of OGG json format by luoyuxia · 2 years, 3 months ago
  95. aa6e30c [FLINK-24745][format][json] Support Oracle OGG json format by wgzhao · 2 years, 6 months ago
  96. d8566a8 [FLINK-25391][format-json] Forward catalog table options by slinkydeveloper · 2 years, 4 months ago
  97. ca7413a [FLINK-25391][format-avro] Forward catalog table options by slinkydeveloper · 2 years, 4 months ago
  98. f5ca5ea [FLINK-25504][Kafka] Upgrade Confluent to v6.2.2 and Kafka-Client to 2.8.1 by martijnvisser · 2 years, 4 months ago
  99. ebaa169 [FLINK-25390][connector-kafka][json] Show usage of helper to forward and merge options by slinkydeveloper · 2 years, 4 months ago
  100. ede46ea [FLINK-25362][docs] fix maven instructions for "Confluent Avro Format" by Nico Kruber · 2 years, 5 months ago