Google Git
Sign in
apache / flink-connector-kafka / HEAD
  1. 4c03d60 [hotfix][docs] Optimize the Security part in docs by Hang Ruan · 3 weeks ago main
  2. 27a5465 [FLINK-28758] Fix stop-with-savepoint for FlinkKafkaConsumer by Piotr Nowojski · 2 weeks ago
  3. 818d1fd [FLINK-33017] Remove dependency on shaded guava by Alex Sorokoumov · 3 weeks ago
  4. d6525c1 [FLINK-31208][Connectors/Kafka] KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits) by Hongshun Wang · 5 months ago
  5. 79ae2d7 [FLINK-32591][Connectors/Kafka] Update document of Kafka Source: Enable Dynamic Partition Discovery by Default in Kafka Source by Hongshun Wang · 2 months ago
  6. 811716c [FLINK-32020] Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288 by Hongshun Wang · 5 months ago
  7. 9109722 [FLINK-31408] Add support for EOS delivery-guarantee in upsert-kafka by Alex Sorokoumov · 7 months ago
  8. 21d3b10 [FLINK-32453] Ambiguous assertThat call after upgrade to Flink 1.18 by Tzu-Li (Gordon) Tai · 3 months ago
  9. 97dbfca [FLINK-32455] Copy over TypeSerializerUpgradeTestBase due to breaking change in Flink 1.18 by Tzu-Li (Gordon) Tai · 3 months ago
  10. 14d8462 [FLINK-32021][kafka] Improve the java docs of SpecifiedOffsetsInitializer and TimestampOffsetsInitializer by Hongshun Wang · 3 months ago
  11. ad62c13 [FLINK-32019][Connector/Kafka] EARLIEST offset strategy for partitions discoveried later based on FLIP-288 by Hongshun Wang · 5 months ago
  12. c1e3527 [FLINK-32462] Pin the used shaded version of Guava and Jackson in the Kafka connector by Martijn Visser · 3 months ago
  13. 910fc5a [FLINK-31747] Remove Confluent Avro formats from externalized Kafka connector repo by Tzu-Li (Gordon) Tai · 4 months ago
  14. 27e2bd3 [FLINK-32289][docs] Fix incorrect metadata column type in examples by yuxiqian · 4 months ago
  15. 2244688 [FLINK-32172][kafka] KafkaExampleUtils incorrect check of the minimum number of parameters (#30) by Weijie Guo · 4 months ago
  16. fc526a8 Update version to 3.1-SNAPSHOT by Tzu-Li (Gordon) Tai · 6 months ago
  17. c9f8aa9 [hotfix] [flink-connector-kafka] Simplify ProducerRecord instantiation w.r.t. headers by Tzu-Li (Gordon) Tai · 6 months ago
  18. a778563 [FLINK-31049] [flink-connector-kafka] Add support for Kafka record headers to KafkaSink by Alex Gout · 6 months ago
  19. 96780b9 [FLINK-31747] remove debezium json for now by mas-chen · 6 months ago
  20. d762d01 [FLINK-30859] Externalize confluent avro related code by mas-chen · 6 months ago
  21. 0d30880 [hotfix] Update copyright NOTICE year to 2023 by Robert Metzger · 6 months ago
  22. 453592b [hotfix] Sort NOTICE dependencies in alphabetical order by Martijn Visser · 7 months ago
  23. f1a078c [FLINK-31485][Confluent Avro] Change packaging of Schema Registry so that by default everything is included. by Martijn Visser · 7 months ago
  24. 6f905fb [FLINK-31085][formats] Add schema option to confluent registry avro formats by Fruzsina Nagy · 7 months ago
  25. 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 · 7 months ago
  26. 35ac273 Update version to 1.18-SNAPSHOT by Leonard Xu · 8 months ago
  27. ad930a4 [FLINK-29638][connectors][filesystems][formats] Update Jackson-BOM to 2.13.4.2 by Sergey Nuyanzin · 12 months ago
  28. d9a80bd [FLINK-28405][Connector/Kafka] Update Confluent Platform images used for testing to v7.2.2. This closes #20170 by MartijnVisser · 12 months ago
  29. 85e5ca6 [FLINK-29468][connectors][filesystems][formats] Update Jackson-BOM to 2.13.4. by Sergey Nuyanzin · 1 year ago
  30. a81eba6 [FLINK-29513][Connector/Kafka] Update Kafka to version 3.2.3 which contains certain security fixes by Martijn Visser · 12 months ago
  31. 9975414 [FLINK-25868][build] Disable japicmp in packaging/e2e modules by Chesnay Schepler · 1 year, 8 months ago
  32. 4abce4b Update version to 1.17-SNAPSHOT by huangxingbo · 1 year, 1 month ago
  33. 54d3c6c [FLINK-24718] Update Avro dependency to 1.11.1 by Ryan Skraba · 1 year, 1 month ago
  34. e71024c [FLINK-28676] Update copyright year to 2014-2022 in NOTICE files by Benchao Li · 1 year, 2 months ago
  35. 077210b [FLINK-28060][kafka] Bump Kafka to 3.2.1 by Chesnay Schepler · 1 year, 2 months ago
  36. f34906d [FLINK-28621][core] Add central Jackson mapper factory methods by Chesnay Schepler · 1 year, 2 months ago
  37. a6b822a [FLINK-28621][formats] Initialize mappers in open() by Chesnay Schepler · 1 year, 2 months ago
  38. a31ac02 [FLINK-28807] Honor schema lifecycle by Chesnay Schepler · 1 year, 2 months ago
  39. 4a141f0 [FLINK-28634][json] Deprecate JsonNodeDeserializationSchema by Chesnay Schepler · 1 year, 2 months ago
  40. bbc81ba [FLINK-28634][json] Add simple JsonSerDeSchema by Chesnay Schepler · 1 year, 2 months ago
  41. 95f315e [FLINK-28222][json] Add flink-sql-json module by Chesnay Schepler · 1 year, 3 months ago
  42. 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, 3 months ago
  43. dd6c275 [FLINK-27442][Formats][Avro Confluent] Add Confluent repo to module flink-sql-avro-confluent-registry by MartijnVisser · 1 year, 5 months ago
  44. 0ff1cd0 [hotfix][json][tests] Fix location of services directory by Chesnay Schepler · 1 year, 5 months ago
  45. 2371b92 [FLINK-27352][json][tests] Migrate flink-json to JUnit5 by BiGsuw · 1 year, 5 months ago
  46. 3507b28 [FLINK-24721][build] Remove unnecessary relativePath to parent by Chesnay Schepler · 1 year, 5 months ago
  47. a56a132 [FLINK-26011][json][test] add ArchUnit tests for the test code by Jing Ge · 1 year, 6 months ago
  48. 1b0ab39 [FLINK-26011][avro-confluent-registry][test] add ArchUnit tests for the test code by Jing Ge · 1 year, 6 months ago
  49. 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 · 1 year, 6 months ago
  50. 9beeb21 [FLINK-26736][tests] Migrate flink-avro-confluent-registry to JUnit5 by Ryan Skraba · 1 year, 6 months ago
  51. 4b1ca3e Update version to 1.16-SNAPSHOT by Yun Gao · 1 year, 7 months ago
  52. d2b7bb3 [FLINK-24745][format][json] Improve the metadata tests and documentation of OGG json format by luoyuxia · 1 year, 8 months ago
  53. aa6e30c [FLINK-24745][format][json] Support Oracle OGG json format by wgzhao · 1 year, 11 months ago
  54. d8566a8 [FLINK-25391][format-json] Forward catalog table options by slinkydeveloper · 1 year, 9 months ago
  55. ca7413a [FLINK-25391][format-avro] Forward catalog table options by slinkydeveloper · 1 year, 9 months ago
  56. f5ca5ea [FLINK-25504][Kafka] Upgrade Confluent to v6.2.2 and Kafka-Client to 2.8.1 by martijnvisser · 1 year, 9 months ago
  57. ebaa169 [FLINK-25390][connector-kafka][json] Show usage of helper to forward and merge options by slinkydeveloper · 1 year, 9 months ago
  58. ede46ea [FLINK-25362][docs] fix maven instructions for "Confluent Avro Format" by Nico Kruber · 1 year, 10 months ago
  59. 862df07 [FLINK-25229][table] Introduce flink-table-api-bridge-base by slinkydeveloper · 1 year, 10 months ago
  60. d084a7c [FLINK-25114][table-runtime] Remove flink-scala dependency and scala suffix by slinkydeveloper · 1 year, 10 months ago
  61. 90ddb4f [FLINK-24687][table][connectors] Move FileSystemTableSink, FileSystemTableSource to flink-connector-files and columnar support to flink-table-common by slinkydeveloper · 1 year, 10 months ago
  62. d50867d [FLINK-25060][table-common] Replace projection methods of FLINK-24399 with the new Projection util by slinkydeveloper · 1 year, 10 months ago
  63. 868da97 [FLINK-25039][build] Disable shading of test jar by default by Chesnay Schepler · 1 year, 10 months ago
  64. 9aa0925 [FLINK-24776][table] Clarify DecodingFormat and introduce ProjectableDecodingFormat by slinkydeveloper · 1 year, 11 months ago
  65. 13a86e6 [FLINK-24715][connectors][filesystems][formats] Update multiple Jackson dependencies to latest version by martijnvisser · 1 year, 11 months ago
  66. 20cc1d8 [FLINK-24673][formats] Deprecate old Row SerializationSchema/DeserializationSchema by slinkydeveloper · 1 year, 11 months ago
  67. b01a973 [FLINK-24599][table] Replace static methods with convenient methods in LogicalType by Marios Trivyzas · 2 years ago
  68. e6d1ef6 [FLINK-24018][build] Remove Scala dependencies from Java APIs by Chesnay Schepler · 1 year, 11 months ago
  69. 6561133 [FLINK-24281][connectors/kafka] Migrate all format tests from FlinkKafkaProducer to KafkaSink by Fabian Paul · 2 years ago
  70. bd82131 [FLINK-23607][state/changelog] Make Changelog Backend a transitive dependency by Roman Khachatryan · 2 years, 1 month ago
  71. ec97614 [FLINK-24034] Upgrade apache commons dependencies by MartijnVisser · 2 years, 1 month ago
  72. dcae1cc Update version to 1.15-SNAPSHOT by Xintong Song · 2 years, 1 month ago
  73. 918235f [FLINK-23044][docs] Fix typos by hapihu · 2 years, 1 month ago
  74. 54ab781 [FLINK-23192][table] Move connector & format options to consistent packages by Ingo Bürk · 2 years, 2 months ago
  75. f08f6e7 [FLINK-23513] Remove format descriptors by Ingo Bürk · 2 years, 2 months ago
  76. 1649c9c [FLINK-23450][avro-confluent-registry] Set properties map for DebeziumAvroFormat by Timo Walther · 2 years, 2 months ago
  77. 1bce2e2 [FLINK-18783] Load Akka with separate classloader by Chesnay Schepler · 2 years, 3 months ago
  78. e75bcdb Revert "[FLINK-18783] Load Akka with separate classloader" by Piotr Nowojski · 2 years, 3 months ago
  79. 47a10d6 [FLINK-18783] Load Akka with separate classloader by Chesnay Schepler · 2 years, 3 months ago
  80. a9bca2b [FLINK-23064][format-avro][format-avro-confluent-registry] Expose config options as PublicEvolving by Ingo Bürk · 2 years, 3 months ago
  81. 6df5e27 [FLINK-23064][format-json] Make JsonOptions PublicEvolving by Ingo Bürk · 2 years, 3 months ago
  82. 7f2ff96 [FLINK-22879][table] Rename flink-table-planner-blink to flink-table-planner by Timo Walther · 2 years, 3 months ago
  83. c611980 [FLINK-22879][table] Rename flink-table-runtime-blink to flink-table-runtime by Timo Walther · 2 years, 3 months ago
  84. e3a499b [FLINK-21448] Add dependency for ChangelogStateBackend ITTests by Yangyang ZHANG · 2 years, 3 months ago
  85. 58893ed [FLINK-22880][table] Remove 'blink' term from code base by Timo Walther · 2 years, 3 months ago
  86. 900a198 [FLINK-21229][docs] Update avro-confluent docs by Timo Walther · 2 years, 3 months ago
  87. 0b915bf [FLINK-21229][avro-confluent-registry] Add Confluent schema registry SSL support by Lars Bachmann · 2 years, 5 months ago
  88. 329193f [FLINK-21229][avro-confluent-registry] Shorten RegistryAvroOptions by Timo Walther · 2 years, 3 months ago
  89. 1b4cc85 [FLINK-20926][maxwell][json] Allow to read metadata for maxwell-json format by SteNicholas · 2 years, 4 months ago
  90. 40d8e22 [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializing for json and csv format. by 莫辞 · 2 years, 4 months ago
  91. 07ba2fa Update version to 1.14-SNAPSHOT by GuoWei Ma · 2 years, 5 months ago
  92. 0fbe0ca [hotfix] Package format-common to flink-csv/flink-json (#15394) by Leonard Xu · 2 years, 6 months ago
  93. 9fef485 [FLINK-21947][csv] Support TIMESTAMP_LTZ type in CSV format by Leonard Xu · 2 years, 6 months ago
  94. 5818335 [FLINK-21913][table][connectors] Update DynamicTableFactory.Context to use ResolvedCatalogTable by Timo Walther · 2 years, 7 months ago
  95. ed7b269 [FLINK-21620][table] Support abbreviation TIMESTAMP_LTZ for TIMESTAMP WITH LOCAL TIME ZONE by Leonard Xu · 2 years, 7 months ago
  96. 942784c [FLINK-21176][docs-zh] Translate the updates of 'avro-confluent.md' to Chinese by yangsanity · 2 years, 7 months ago
  97. 9f8a7fd [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo by Seth Wiesman · 2 years, 8 months ago
  98. 9cd50f6 [FLINK-21172][canal][json] Support 'event-timestampcanal-json format include es field (#14792) by SteNicholas · 2 years, 8 months ago
  99. 17c5aaa [FLINK-21020][build] Bump Jackson to 2.12.1 by huangxingbo · 2 years, 8 months ago
  100. f717f27 [FLINK-19446][canal-json] Fix canal-json format parse UPDATE record with null value will get wrong result by SteNicholas · 2 years, 8 months ago