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