Google Git
Sign in
apache / flink-connector-kafka / HEAD
  1. 862df07 [FLINK-25229][table] Introduce flink-table-api-bridge-base by slinkydeveloper · 2 years, 6 months ago
  2. d084a7c [FLINK-25114][table-runtime] Remove flink-scala dependency and scala suffix by slinkydeveloper · 2 years, 6 months ago
  3. 90ddb4f [FLINK-24687][table][connectors] Move FileSystemTableSink, FileSystemTableSource to flink-connector-files and columnar support to flink-table-common by slinkydeveloper · 2 years, 6 months ago
  4. d50867d [FLINK-25060][table-common] Replace projection methods of FLINK-24399 with the new Projection util by slinkydeveloper · 2 years, 6 months ago
  5. 868da97 [FLINK-25039][build] Disable shading of test jar by default by Chesnay Schepler · 2 years, 6 months ago
  6. 9aa0925 [FLINK-24776][table] Clarify DecodingFormat and introduce ProjectableDecodingFormat by slinkydeveloper · 2 years, 7 months ago
  7. 13a86e6 [FLINK-24715][connectors][filesystems][formats] Update multiple Jackson dependencies to latest version by martijnvisser · 2 years, 7 months ago
  8. 20cc1d8 [FLINK-24673][formats] Deprecate old Row SerializationSchema/DeserializationSchema by slinkydeveloper · 2 years, 7 months ago
  9. b01a973 [FLINK-24599][table] Replace static methods with convenient methods in LogicalType by Marios Trivyzas · 2 years, 7 months ago
  10. e6d1ef6 [FLINK-24018][build] Remove Scala dependencies from Java APIs by Chesnay Schepler · 2 years, 7 months ago
  11. 6561133 [FLINK-24281][connectors/kafka] Migrate all format tests from FlinkKafkaProducer to KafkaSink by Fabian Paul · 2 years, 8 months ago
  12. bd82131 [FLINK-23607][state/changelog] Make Changelog Backend a transitive dependency by Roman Khachatryan · 2 years, 9 months ago
  13. ec97614 [FLINK-24034] Upgrade apache commons dependencies by MartijnVisser · 2 years, 9 months ago
  14. dcae1cc Update version to 1.15-SNAPSHOT by Xintong Song · 2 years, 9 months ago
  15. 918235f [FLINK-23044][docs] Fix typos by hapihu · 2 years, 9 months ago
  16. 54ab781 [FLINK-23192][table] Move connector & format options to consistent packages by Ingo Bürk · 2 years, 10 months ago
  17. f08f6e7 [FLINK-23513] Remove format descriptors by Ingo Bürk · 2 years, 10 months ago
  18. 1649c9c [FLINK-23450][avro-confluent-registry] Set properties map for DebeziumAvroFormat by Timo Walther · 2 years, 10 months ago
  19. 1bce2e2 [FLINK-18783] Load Akka with separate classloader by Chesnay Schepler · 2 years, 11 months ago
  20. e75bcdb Revert "[FLINK-18783] Load Akka with separate classloader" by Piotr Nowojski · 2 years, 11 months ago
  21. 47a10d6 [FLINK-18783] Load Akka with separate classloader by Chesnay Schepler · 2 years, 11 months ago
  22. a9bca2b [FLINK-23064][format-avro][format-avro-confluent-registry] Expose config options as PublicEvolving by Ingo Bürk · 2 years, 11 months ago
  23. 6df5e27 [FLINK-23064][format-json] Make JsonOptions PublicEvolving by Ingo Bürk · 2 years, 11 months ago
  24. 7f2ff96 [FLINK-22879][table] Rename flink-table-planner-blink to flink-table-planner by Timo Walther · 2 years, 11 months ago
  25. c611980 [FLINK-22879][table] Rename flink-table-runtime-blink to flink-table-runtime by Timo Walther · 2 years, 11 months ago
  26. e3a499b [FLINK-21448] Add dependency for ChangelogStateBackend ITTests by Yangyang ZHANG · 3 years ago
  27. 58893ed [FLINK-22880][table] Remove 'blink' term from code base by Timo Walther · 3 years ago
  28. 900a198 [FLINK-21229][docs] Update avro-confluent docs by Timo Walther · 3 years ago
  29. 0b915bf [FLINK-21229][avro-confluent-registry] Add Confluent schema registry SSL support by Lars Bachmann · 3 years, 1 month ago
  30. 329193f [FLINK-21229][avro-confluent-registry] Shorten RegistryAvroOptions by Timo Walther · 3 years ago
  31. 1b4cc85 [FLINK-20926][maxwell][json] Allow to read metadata for maxwell-json format by SteNicholas · 3 years ago
  32. 40d8e22 [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializing for json and csv format. by 莫辞 · 3 years ago
  33. 07ba2fa Update version to 1.14-SNAPSHOT by GuoWei Ma · 3 years, 1 month ago
  34. 0fbe0ca [hotfix] Package format-common to flink-csv/flink-json (#15394) by Leonard Xu · 3 years, 2 months ago
  35. 9fef485 [FLINK-21947][csv] Support TIMESTAMP_LTZ type in CSV format by Leonard Xu · 3 years, 2 months ago
  36. 5818335 [FLINK-21913][table][connectors] Update DynamicTableFactory.Context to use ResolvedCatalogTable by Timo Walther · 3 years, 2 months ago
  37. ed7b269 [FLINK-21620][table] Support abbreviation TIMESTAMP_LTZ for TIMESTAMP WITH LOCAL TIME ZONE by Leonard Xu · 3 years, 3 months ago
  38. 942784c [FLINK-21176][docs-zh] Translate the updates of 'avro-confluent.md' to Chinese by yangsanity · 3 years, 3 months ago
  39. 9f8a7fd [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo by Seth Wiesman · 3 years, 4 months ago
  40. 9cd50f6 [FLINK-21172][canal][json] Support 'event-timestampcanal-json format include es field (#14792) by SteNicholas · 3 years, 4 months ago
  41. 17c5aaa [FLINK-21020][build] Bump Jackson to 2.12.1 by huangxingbo · 3 years, 4 months ago
  42. f717f27 [FLINK-19446][canal-json] Fix canal-json format parse UPDATE record with null value will get wrong result by SteNicholas · 3 years, 4 months ago
  43. f4edddf [FLINK-20953][canal-json] Support regular expression to filter databases and tables for canal-json by SteNicholas · 3 years, 4 months ago
  44. 842359a [FLINK-20885][canal-json] Fix deserialization exception when using 'canal-json.table.include' to filter binlogs of multiple tables by SteNicholas · 3 years, 4 months ago
  45. 6be35ca [FLINK-20861][json] Introduce an option for serializing DECIMALs in JSON as plain number instead of scientific notation by LM Kang · 3 years, 4 months ago
  46. 42cd733 [FLINK-20906][legal] Update copyright year to 2021 for NOTICE files. by Xintong Song · 3 years, 5 months ago
  47. 0b7fce0 [FLINK-20321][formats] Fix NPE when using Avro/Json/Csv formats to deserialize null input (#14539) by Xue Wang · 3 years, 5 months ago
  48. b53a936 [FLINK-20773][json] Support to parse unescaped control chars in string node by V1ncentzzZ · 3 years, 5 months ago
  49. 1299112 [FLINK-18090] Update tests for new Row.toString by Timo Walther · 3 years, 5 months ago
  50. a3a9368 [FLINK-20841][git] Remove .gitignore entries for generated files by Matthias Pohl · 3 years, 5 months ago
  51. 6a81b61 [FLINK-20385][canal-json] Allow to read metadata for canal-json format by SteNicholas · 3 years, 5 months ago
  52. e88df03 [FLINK-20790][build][avro] Move generated files to target/generated[-test]-sources by Chesnay Schepler · 3 years, 5 months ago
  53. fbf6bf1 [FLINK-20651] Format code with Spotless/google-java-format by Rufus Refactor · 3 years, 5 months ago
  54. 954ef1b [FLINK-19880][json] Fix ignore-parse-errors option not work for the legacy JSON format by cxiiiiiii · 3 years, 5 months ago
  55. 93ce729 [FLINK-20470][json] MissingNode can't be casted to ObjectNode when deserializing JSON by zhuxiaoshang · 3 years, 6 months ago
  56. 3b61f33 Update version to 1.13-SNAPSHOT by Dian Fu · 3 years, 6 months ago
  57. 45fd0b4 [hotfix] Shade avro in sql-avro jars by Dawid Wysakowicz · 3 years, 6 months ago
  58. fb84e62 [FLINK-20295][table][fs-connector] Table File Source lost data when reading from directories with JSON format by Jingsong Lee · 3 years, 6 months ago
  59. 7113361 [hotfix][json] Consider nullability for Debezium ingestion timestamp by Timo Walther · 3 years, 6 months ago
  60. ea1af30 [FLINK-20170][json] Fix JSON format loses precision when deserializing decimals by caozhen · 3 years, 6 months ago
  61. 48f6d29 [FLINK-20147][json] Replace lambdas with classes to prevent serialization issues by Timo Walther · 3 years, 6 months ago
  62. aa4a291 [FLINK-19912][json] Fix JSON format fails to serialize map value with null keys by wangxlong · 3 years, 7 months ago
  63. a1c3e9d [FLINK-18774][debezium-avro] Improve debezium-avro format implementation by Jark Wu · 3 years, 7 months ago
  64. 1dd7a3a [FLINK-18774][debezium-avro] Support debezium avro format by caozhen1937 · 3 years, 9 months ago
  65. 2f6933d [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema by Jingsong Lee · 3 years, 7 months ago
  66. 7bfb2b4 [FLINK-19276][json][connector-kafka] Support reading Debezium metadata by Timo Walther · 3 years, 7 months ago
  67. 719b390 [FLINK-18546] Upgrade to Kafka Schema Registry Client 5.5.2 by Dawid Wysakowicz · 3 years, 7 months ago
  68. 9b8b7b4 [FLINK-19849] Fix NOTICE files for 1.12 release by Robert Metzger · 3 years, 7 months ago
  69. 26e9b18 [FLINK-19790][json] Clear reused ObjectNode's content for map converter in RowDataToJsonConverters by Benchao Li · 3 years, 7 months ago
  70. 7fbc65d [FLINK-19873][canal-json] Skip DDL change events for Canal data by fangliang · 3 years, 7 months ago
  71. 11dcb83 [FLINK-19786][avro] Fix the nullability and precision for Avro format deserialization by yuzhao.cyz · 3 years, 7 months ago
  72. b86a6e2 [FLINK-19779][avro] Remove the "record_" field name prefix for Avro format deserialization by yuzhao.cyz · 3 years, 7 months ago
  73. ef72378 [hotfix][json] Add serialVersionUID to JsonInputFormat class by wangxlong · 3 years, 7 months ago
  74. c883034 [hotfix][table-common] Avoid unnecessary casting when creating type information in sources and sinks by Timo Walther · 3 years, 7 months ago
  75. 2e4a694 [FLINK-17528][table] Remove ArrayData#get() API and use ElementGetter instead by Jark Wu · 3 years, 7 months ago
  76. 13d7fbb [FLINK-17528][table] Remove RowData#get() API and use FieldGetter instead by Jark Wu · 3 years, 7 months ago
  77. 839f96a [FLINK-18999][table-common][table-planner-blink] Add isTemporary flag to table factory context by Rui Li · 3 years, 9 months ago
  78. edf51f6 [FLINK-19509][json] Support MULTISET type for JSON format by wangxlong · 3 years, 8 months ago
  79. 1c7ecd9 [FLINK-19098][json][csv] Make RowData CSV and JSON converters public by Brian Zhou · 3 years, 8 months ago
  80. fca2c3f [FLINK-19002][canal][json] Support to only read changelogs of specific database and table for canal-json format by Jark Wu · 3 years, 8 months ago
  81. 7d74f65 [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors by Aljoscha Krettek · 3 years, 9 months ago
  82. 55f493e [FLINK-18192] Upgrade avro to 1.10 by Dawid Wysakowicz · 3 years, 9 months ago
  83. f30075d [FLINK-18823][format] Support serialization for debezium-json format by SteNicholas · 3 years, 9 months ago
  84. 3776d1e [FLINK-18824][json][table] Support serialization for canal-json format by caozhen · 3 years, 9 months ago
  85. bad1aeb [hoxfix] Fix various typos by Brandon · 3 years, 9 months ago
  86. 5260033 [FLINK-18844][json][maxwell] Support maxwell-json format to read Maxwell changelogs by dijie · 3 years, 10 months ago
  87. b76981e [FLINK-18705][debezium] Fix Debezium-JSON throws NPE when tombstone message is received by Jark Wu · 3 years, 10 months ago
  88. 5561317 [FLINK-18700][debezium] Debezium-json format throws NPE when PG table's IDENTITY config is not FULL by Jark Wu · 3 years, 10 months ago
  89. ae8ac94 [FLINK-18776][avro] Avoid hardcoded scala version by Dian Fu · 3 years, 10 months ago
  90. 1380f0e [FLINK-16048][avro] Support read/write confluent schema registry avro data from Kafka by Danny Chan · 3 years, 10 months ago
  91. 7006696 [FLINK-18607][build] Give the maven module a human readable name by Niels Basjes · 3 years, 10 months ago
  92. ed9f5af [FLINK-18296][json] Add support for TIMESTAMP_WITH_LOCAL_ZONE type for Json format by Shengkai · 4 years ago
  93. fbc291f [FLINK-18537][table] Replace RowDataTypeInfo with InternalTypeInfo by Timo Walther · 3 years, 11 months ago
  94. 1acd122 [FLINK-18002][json] Correct the behavior for ContainerNode as varchar type by libenchao · 4 years ago
  95. bc8d5a7 [FLINK-17000][table] Ensure that every logical type can be represented as TypeInformation by Timo Walther · 4 years ago
  96. bd6467a [FLINK-18299][json] Fix the non SQL standard timestamp format in JSON format by Shengkai · 4 years ago
  97. 3a9bc13 [FLINK-17887][table][connector] Improve interface of ScanFormatFactory and SinkFormatFactory by Jark Wu · 4 years ago
  98. b77f97c [hotfix][tests] Move containsCause to FlinkMatchers by Timo Walther · 4 years ago
  99. 20223de [FLINK-17925][fs-connector] Fix Filesystem options to default values and types by Jingsong Lee · 4 years ago
  100. 541477a [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style by Jingsong Lee · 4 years ago