Google Git
Sign in
apache / flink-connector-kafka / HEAD
  1. 5384ab2 [FLINK-37714][Connector/Kafka] Generate entities in a temporary folder while tests by Sergey Nuyanzin · 4 weeks ago main
  2. 89badde [FLINK-36659][docs] Update weekly.yml by Arvid Heise · 4 weeks ago
  3. 2bc999b [FLINK-37644] Enforce precise dependencies + ban offenders by Arvid Heise · 5 weeks ago
  4. e874476 [FLINK-37644] Remove jetbrains annotations by Arvid Heise · 6 weeks ago
  5. 39a1f2b [FLINK-37644] Remove unused code and commons-collection by Arvid Heise · 6 weeks ago
  6. 35de2ce [FLINK-37644] Remove flink-shaded-jackson by Arvid Heise · 6 weeks ago
  7. c1442ea [FLINK-37644] Remove mockito by Arvid Heise · 6 weeks ago
  8. d44f574 [FLINK-37644] Remove guava from prod code by Arvid Heise · 6 weeks ago
  9. 16c8559 [hotfix] Updated NOTICE to 2025 by Arvid Heise · 6 weeks ago
  10. 4606010 [FLINK-37622] Fix KafkaSink in BATCH by Arvid Heise · 6 weeks ago
  11. 2b199b0 [hotfix] Harden KafkaWriterFaultToleranceITCase by Arvid Heise · 6 weeks ago
  12. 91b048d [FLINK-34554] Adding strategies to table API by Arvid Heise · 3 months ago
  13. 2d4f402 [FLINK-34554] Adding pooling name strategy by Arvid Heise · 3 months ago
  14. fb28015 [FLINK-34554] Adding listing abort strategy by Arvid Heise · 7 weeks ago
  15. d43fcbd [FLINK-34554] Introduce transaction strategies by Arvid Heise · 3 months ago
  16. 45df794 [hotfix] Remove unused method by Rui Fan · 4 months ago
  17. a84c2b8 [FLINK-37613] Fix resource leak during abortion by Arvid Heise · 7 weeks ago
  18. d74a7bd [FLINK-37611] Deflake KafkaWriterFaultToleranceITCase.testWriteExceptionWhenKafkaUnavailable by Arvid Heise · 6 weeks ago
  19. 765b1e7 [FLINK-37611] Deflake ExactlyOnceKafkaWriterITCase#shouldAbortLingeringTransactions by Arvid Heise · 6 weeks ago
  20. 1b9b1aa [FLINK-37304][connector/kafka] Downgrade the log level of metadataUpdateEvent in DynamicKafkaSourceEnumerator to avoid displaying connection information by Kunni · 7 weeks ago
  21. 11c2264 Fix compatibility with 2.1-SNAPSHOT. by lvyanquan · 7 weeks ago
  22. df7d347 [FLINK-37590][build] Add CI of python and add jdk11 to ensure compatibility. by lvyanquan · 7 weeks ago
  23. 6f251ec [FLINK-37356] Remove transaction reset by Arvid Heise · 7 weeks ago
  24. ad3ef74 [FLINK-37356] Recreate producer on error by Arvid Heise · 8 weeks ago
  25. 1dc5c1a [FLINK-36821] Update to Kafka 3.9.0 by Thomas Cooper · 6 months ago
  26. 33f34c2 [FLINK-37144][Connectors/Kafka] Update version to 4.0-SNAPSHOT by Kunni · 7 weeks ago
  27. c280545 [hotfix][build] Add stable version to weekly CI by lvyanquan · 8 weeks ago
  28. 9996019 [FLINK-36648][Connectors/Kafka] Bump Flink version to 2.0.0 by lvyanquan · 8 weeks ago
  29. 2fdb66d [FLINK-36848][Connectors/Kafka] Remove Deprecated class and relevant tests. by lvyanquan · 6 months ago
  30. 33d0022 [FLINK-36630][Connectors/Kafka] Wrap consumer.position in retryOnWakeup (#133) by trompa · 2 months ago
  31. 7c112ab [FLINK-37380][connector/kafka] Change TransactionalIdPrefix as required option when Exactly-Once enabled by Hongshun Wang · 3 months ago
  32. dd7d848 [FLINK-37396][build] Use multiple top-level packages discovered in a flat-layout in setup.py by Hongshun Wang · 3 months ago
  33. a52f15a [FLINK-33265] Support source parallelism setting for Kafka connector by Zhanghao Chen · 6 months ago
  34. f4015d1 [FLINK-37282] Incorporate Backchannel and ProducerPool into EOSWriter by Arvid Heise · 3 months ago
  35. d3c3546 [FLINK-37282] Force colocation of kafka writer and kafka committer. by Arvid Heise · 3 months ago
  36. 580d3ed [FLINK-37282] Add ProducerPool by Arvid Heise · 3 months ago
  37. db07aa6 [FLINK-37282] Add Backchannel by Arvid Heise · 3 months ago
  38. df353e9 [FLINK-37282] Split KafkaWriter into EOS/non-EOS by Arvid Heise · 3 months ago
  39. 2e652a9 [hotfix] Fix leaks in FlinkKafkaProducerTest by Arvid Heise · 3 months ago
  40. 5947f3c [FLINK-37282] Introduce internal package to sink by Arvid Heise · 3 months ago
  41. 707ec4c [FLINK-37281] Fix KafkaUtil#checkProducerLeak by Arvid Heise · 3 months ago
  42. ee3d713 [FLINK-37281] Improve extensibility in KafkaWriterTestBase by Arvid Heise · 3 months ago
  43. 8bb953d [FLINK-37281] Refactor KafkaSinkITCase by Arvid Heise · 3 months ago
  44. 20809da [hotfix] Remote dead code by Arvid Heise · 3 months ago
  45. f6a077a [FLINK-36780] Kafka source disable partition discovery unexpectedly (#136) by Mingliang Liu · 6 months ago
  46. 59baacc [FLINK-35109] Update weekly CI to verify 3.4 release branch by Arvid Heise · 6 months ago
  47. 727327d [FLINK-34466] Lineage interfaces for kafka connector (#130) by pawel.leszczynski · 6 months ago
  48. 0fed445 [FLINK-35109] Updating build configurations for v3.3 by Arvid Heise · 7 months ago
  49. 2dfdae6 [FLINK-34467] bump flink version to 1.20.0 (#111) by Peter Huang · 7 months ago
  50. c2e11a6 [FLINK-35109] Update version to 3.4-SNAPSHOT by Arvid Heise · 7 months ago
  51. 6dc74db Addressing Chesnay's feedback by Arvid Heise · 7 months ago
  52. 7f1ac6d [hotfix] Add maven wrapper by Arvid Heise · 7 months ago
  53. aedc790 [FLINK-35109] Bump to Flink 1.19 and support Flink 1.20 by Arvid Heise · 8 months ago
  54. 429fe0c [FLINK-35109] Fix SmokeKafkaITCase for later java versions by Arvid Heise · 7 months ago
  55. 5eeafd6 [FLINK-36441] Fix KafkaWriterITCase#testIncreasingRecordBasedCounters by Arvid Heise · 8 months ago
  56. 28836c6 [FLINK-36441] Ensure producers are not leaked in tests by Arvid Heise · 8 months ago
  57. 8472d03 [FLINK-36441] Fix leak for non-transactional FlinkKafkaProducer. by Arvid Heise · 7 months ago
  58. ab333a4 [FLINK-36441] Ignore exceptions during test cleanup by Arvid Heise · 8 months ago
  59. a738104 [FLINK-36441] Show full stacktraces in tests for failures by Arvid Heise · 8 months ago
  60. 264ce8c [hotfix] Copy Flink .editorconfig by Arvid Heise · 7 months ago
  61. 3fbb68d [FLINK-36420][Connectors/Kafka] Bump avro from 1.11.3 to 1.11.4 by Danny Cranmer · 8 months ago
  62. ac8fa12 [FLINK-36422][docs] Fix PyFlink jar download link by Aleksandr Pilipenko · 8 months ago
  63. a87bf72 [FLINK-35138][Connectors/Kafka] Drop support for Flink 1.17 by Danny Cranmer · 1 year, 1 month ago
  64. 157813e [FLINK-36177] Introduce KafkaPartitioner to replace FlinkKafkaPartitioner by Arvid Heise · 8 months ago
  65. 21d07b7 [FLINK-36177] Deprecate KafkaShuffle and more by Arvid Heise · 8 months ago
  66. 9b97c51 [hotfix] Fix FlinkKafkaConsumerBaseTest.testClosePartitionDiscovererWithCancellation by Arvid Heise · 8 months ago
  67. 2ee9b9a [hotfix] Remove unused test dependencies by Arvid Heise · 8 months ago
  68. 1b02ce8 [FLINK-36278] Reduce Flink log levels by Arvid Heise · 8 months ago
  69. ec8d7c2 [FLINK-36278] Reduce Kafka log level by Arvid Heise · 8 months ago
  70. 2f86484 [FLINK-36278] Decrease log levels for hotpath logs by Arvid Heise · 8 months ago
  71. c0be7d5 [FLINK-36278] Reduce log size by avoiding container logs by default by Arvid Heise · 8 months ago
  72. 52e7e58 [FLINK-36209] Remove redundant operations in the initialization of KafkaSourceEnumState (#116) by xiaochen · 8 months ago
  73. 122a743 [FLINK-34470][Connectors/Kafka] Fix indefinite blocking by adjusting stopping condition on split reader (#100) by dongwoo kim · 8 months ago
  74. 7929b16 [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode (#117) by xiaochen · 8 months ago
  75. 3730005 [FLINK-22748] Allow dynamic target topic selection in SQL Kafka sinks (#109) by klam-shop · 8 months ago
  76. 268f6b5 [FLINK-36176] Remove support for Kafka 0.1 (#115) by Arvid Heise · 9 months ago
  77. 020bc33 [FLINK-35886] Leave a note for future Flink 2.0 upgrade by Piotr Nowojski · 9 months ago
  78. ea3a641 [FLINK-33201][Connectors/Kafka] Fix memory leak in CachingTopicSelector by Yop Lee · 1 year, 8 months ago
  79. b5b8076 [FLINK-36083][docs] Fix kafka table api doc's Connector Options table broken. (#112) by gongzhongqiang · 9 months ago
  80. 86f796a [FLINK-35808] Let `ConsumerConfig.(KEY|VALUE)_DESERIALIZER_CLASS_CONFIG` be overridable by user in `KafkaSourceBuilder` (#108) by klam-shop · 10 months ago
  81. 4429b78 [FLINK-35749] Kafka sink component will lose data when kafka cluster is unavailable for a while (#107) by Jimmyz · 10 months ago
  82. 15d3fbd [FLINK-35138][Connectors/Kafka] Bump development version to 3.3-SNAPSHOT by Danny Cranmer · 12 months ago
  83. 00c9c8c [FLINK-35228][Connectors/Kafka] Fix: DynamicKafkaSource does not read re-added topic for the same cluster (#97) by Ignas Daukšas · 1 year, 1 month ago
  84. 369e7be [FLINK-35038] Bump `org.yaml:snakeyaml` to `2.2` (#93) by Ufuk Celebi · 1 year, 1 month ago
  85. 1c39e3b [FLINK-35008] Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 (#87) by dependabot[bot] · 1 year, 1 month ago
  86. c47abb3 [FLINK-34961] Use dedicated CI name for Kafka connector to differentiate it in infra-reports by Sergey Nuyanzin · 1 year, 1 month ago
  87. 2f5e3cf [hotfix] Add Java 21 as JDK to test for Flink 1.19.0 weekly runs by Martijn Visser · 1 year, 1 month ago
  88. 897001d [FLINK-35007] Add support for Flink 1.19 (#90) by Martijn Visser · 1 year, 1 month ago
  89. 15f2662 [hotfix] Add JDK21 for 1.19-SNAPSHOT by Martijn Visser · 1 year, 3 months ago
  90. 489dd7b [hotfix] Test against Flink 1.19-SNAPSHOT for `main` and Weekly builds by Martijn Visser · 1 year, 3 months ago
  91. 2606a82 [FLINK-34193] Remove usage of Flink-Shaded Jackson and Snakeyaml in flink-connector-kafka by Jiabao Sun · 1 year, 3 months ago
  92. b8328ab [FLINK-34192] Update to be compatible with updated SinkV2 interfaces by Jiabao Sun · 1 year, 3 months ago
  93. cfb275b [FLINK-34244] Update Confluent Platform to 7.4.4. This closes #81 by Martijn Visser · 1 year, 3 months ago
  94. 6d0ffcd [hotfix] Update shortcode in Kafka Datastream documentation so that the download links appear by Martijn Visser · 1 year, 3 months ago
  95. ab356b4 [hotfix] Make the upsert-kafka artifacts point to the regular kafka artifacts in the documentation by Martijn Visser · 1 year, 3 months ago
  96. abf4563 [hotfix] Update copyright year to 2024 (#82) by Hang Ruan · 1 year, 4 months ago
  97. 624f0a1 [hotfix] Update copyright year to 2024 by Martijn Visser · 1 year, 4 months ago
  98. a468c2b [hotfix] Add missing JDK17 test for 1.18 against v3.1 by Martijn Visser · 1 year, 4 months ago
  99. 68ac980 [hotfix] Remove weekly test against 1.19-SNAPSHOT since that's currently broken and tracked under FLINK-34193 by Martijn Visser · 1 year, 4 months ago
  100. fd7b46c [release] Update weekly CI to check against new release branch `v3.1` by Martijn Visser · 1 year, 4 months ago