Google Git
Sign in
apache/flink-connector-kafka/HEAD
  1. 1dbc33b [hotfix] Fix compiler varargs warning in KafkaSinkBuilderTest (#297) by Sylwester Lachiewicz · 28 hours ago main
  2. db222b3 [FLINK-40128][connector] Topic integrity ITCase by Efrat Levitan · 8 weeks ago
  3. a5b7bc3 [FLINK-40128][connector] Implement topic integrity awareness across kafka subscribers by Efrat Levitan · 8 weeks ago
  4. 9cc364d [FLINK-40128][connector] Add an opt-in based topic integrity config option by Efrat Levitan · 8 weeks ago
  5. 564ad82 [FLINK-40128][connector] Introduce topic integrity utilities in static kafka source by Efrat Levitan · 8 weeks ago
  6. dc707db [FLINK-39888][Kafka] Allow configuring offset reset strategy independently (#267) by jigar-bhati · 3 weeks ago
  7. 6540503 [FLINK-40367][Connectors/Kafka] Make Kafka consumer poll timeout configurable (#292) by Purushottam Sinha · 3 weeks ago
  8. aa6be4b [FLINK-40094][Connectors/Kafka] Mark removed DynamicKafkaSource split outputs idle before release (#283) by lnbest0707 · 7 weeks ago
  9. 90d05d5 [FLINK-38919][docs] Document PyFlink per-cluster offsets (#280) by bowenli86 · 9 weeks ago
  10. ccb316c [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes (#278) by bowenli86 · 9 weeks ago
  11. eb8ff70 [FLINK-39728] Fix pauseOrResumeSplits race with unassigned partitions by Jim Hughes · 4 months ago
  12. 6a109ae [hotfix] update reader idleness test output (#281) by bowenli86 · 10 weeks ago
  13. 904e882 [FLINK-39979] DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders (#276) by bowenli86 · 10 weeks ago
  14. 2b8d8e2 [FLINK-39990] Expose DynamicKafkaSource active split count (#277) by lnbest0707 · 2 months ago
  15. 70fb631 [FLINK-39944] Make dynamic Kafka metadata refresh resilient (#274) by lnbest0707 · 2 months ago
  16. cb40de0 [FLINK-39837] Retain removed dynamic Kafka cluster offsets (#264) by lnbest0707 · 3 months ago
  17. 25974e4 [FLINK-39792] Fix headers MAP dropping null values by Arvid Heise · 3 months ago
  18. a6510ee [FLINK-39792] Add header-list metadata key to Kafka connector by Arvid Heise · 3 months ago
  19. d43f3ae [FLINK-39940] DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService (#266) by bowenli86 · 3 months ago
  20. a88f9a5 [FLINK-39892][metrics] Fix incorrect numBytesOut reported delta after producer reset by Efrat Levitan · 3 months ago
  21. fa1021e [FLINK-39608] Change KafkaDatasetFacet to extend DatasetConfigFacet (#246) by Swapna Marru · 3 months ago
  22. ab6182e [FLINK-39822][tests] Wait for partition assignment in test createTopics calls by Aleksandr Savonin · 3 months ago
  23. 86e3d97 [hotfix] Bump project version to `5.1-SNAPSHOT` by Ferenc Csaky · 3 months ago
  24. c4a14cf [hotfix] Update CI workflows after v5.0 release by Ferenc Csaky · 3 months ago
  25. 84d2ee7 [FLINK-39723][tests] Wait for partition assignment in KafkaTableTestBase.createTestTopic by Aleksandr Savonin · 3 months ago
  26. 066daae [FLINK-39705] Remove Zookeeper references by Aleksandr Savonin · 4 months ago
  27. ab300d2 [FLINK-39693] Align jackson-bom to 2.21.3 (Flink master) by Purushottam Sinha · 4 months ago
  28. 119cf49 [FLINK-39693] Bump jackson, log4j, assertj to address CVEs by Purushottam Sinha · 4 months ago
  29. aba208f [hotfix] Bump flink.version to 2.1.2 by Purushottam Sinha · 4 months ago
  30. 887d594 [hotfix] Stabilize KafkaWriterFaultToleranceITCase exception-on-unavailable tests by Aleksandr Savonin · 4 months ago
  31. 443c0f3 [FLINK-39699][tests] Wait for partitions assignment in KafkaSinkITCase by Aleksandr Savonin · 4 months ago
  32. 2d44198 [FLINK-39699][tests] Wait for completed checkpoint stats in KafkaSinkITCase by Aleksandr Savonin · 4 months ago
  33. 0caa1c9 [hotfix] Update Maven Wrapper by Ferenc Csaky · 4 months ago
  34. 11d40cc [FLINK-38790] Update CI to Flink 2.2, adjust code by Ferenc Csaky · 4 months ago
  35. 61f81bd [FLINK-39514] Release dynamic Kafka split outputs on metadata shrink (#245) by lnbest0707 · 4 months ago
  36. 7ec6463 [FLINK-39234][tests] Wait for topic intialization in KafkaWriterTestBase based tests by Efrat Levitan · 6 months ago
  37. c3f8087 [FLINK-39234][tests] Move createNewTopicAndWaitForPartitionAssignment to a shared utils class by Efrat Levitan · 6 months ago
  38. bd2fd2b [FLINK-39338] Fix topic name collisions in KafkaWriterTestBase for parameterized tests by Aleksandr Savonin · 5 months ago
  39. a7e805a [FLINK-39238] Support watermark alignment in dynamic Kafka reader (#240) by lnbest0707 · 6 months ago
  40. 741673e [FLINK-39138] Update `flink-connector-parent` version to 2.0.0 by Thomas Cooper · 6 months ago
  41. 8eab7c9 [hotfix] Update weekly CI versions by Ferenc Csaky · 6 months ago
  42. a42f6a4 [hotfix] Revert [FLINK-38869] InitializationContext for KafkaSubscriber by Efrat Levitan · 6 months ago
  43. ee98785 [FLINK-38999][lineage] License lineage files by Efrat Levitan · 7 months ago
  44. ffb1fc6 [hotfix] Remove unused test infrastructure from KafkaTestBase by Aleksandr Savonin · 7 months ago
  45. c604ce5 [FLINK-29245] Remove unused RetryRule by Aleksandr Savonin · 7 months ago
  46. d678570 [FLINK-39121][tests] Retry kafka containers startup by Efrat Levitan · 6 months ago
  47. e0969a4 [FLINK-39120] Update Kafka version to 4.2.0 by Ferenc Csaky · 7 months ago
  48. 80dadcb [hotfix] Wait for log partitions assignments by Aleksandr Savonin · 7 months ago
  49. 12d4d4b [FLINK-39037] support query kafka cluster id as metadata in records of DynamicKafkaTableSource (#222) by bowenli86 · 7 months ago
  50. a9d2f77 [hotfix] Update testcontainers dependency to fix Ubuntu - Docker compatibility issue by Aleksandr Savonin · 7 months ago
  51. da1a90f [FLINK-39012]Add global kafka enumerator support (#223) by lnbest0707 · 7 months ago
  52. 7ef6c44 [hotfix] Wait for leader election to prevent OUT_OF_ORDER issues by Aleksandr Savonin · 7 months ago
  53. cdbd635 [FLINK-39013] add E2E test for DynamicKafkaTableSource (#218) by bowenli86 · 7 months ago
  54. 22d09e6 [FLINK-25538] Added ArchUnit rule (BanJunit4Rules) to prevent future JUnit 4 usage by Aleksandr Savonin · 7 months ago
  55. 6f04b28 [FLINK-25538] Remove optional public modifiers from test classes and methods following JUnit 5 best practices. by Aleksandr Savonin · 7 months ago
  56. 1db38de [FLINK-25538] Replaces individual @ExtendWith(TestLoggerExtension.class) annotations with global SPI registration by Aleksandr Savonin · 7 months ago
  57. 7e64c26 [FLINK-25538] Migrate tests from JUnit 4 to JUnit 5 by Aleksandr Savonin · 7 months ago
  58. a550534 [hotfix] Apply spotless formatting by Aleksandr Savonin · 7 months ago
  59. e75c00e [FLINK-38937] Rename KAFKA constant to CP_KAFKA for clarity by Aleksandr Savonin · 8 months ago
  60. 2902e3b [FLINK-38937] Migrate all Kafka tests to TestKafkaContainer with KRaft mode by Aleksandr Savonin · 8 months ago
  61. 160ee7f [FLINK-38937] Introduce TestKafkaContainer wrapper for Apache and Confluent Kafka images by Aleksandr Savonin · 8 months ago
  62. 5cd6e46 [FLINK-38869] InitializationContext for KafkaSubscriber (#208) by Efrat Levitan · 7 months ago
  63. d0b5cca [FLINK-38920] create Table source and factory for DynamicKafkaSource in Flink Table API (#212) by bowenli86 · 8 months ago
  64. f2e6b34 [FLINK-38947] Handle errors in onCompletion callback only once (#214) by Roman · 8 months ago
  65. dc4efea [FLINK-38917][docs] Add documentation about Python DynamicKafkaSource (#211) by bowenli86 · 8 months ago
  66. 5b69b2b [FLINK-38876] Support per-cluster offset in Dynamic Kafka Source (#209) by bowenli86 · 8 months ago
  67. 20ca57d [FLINK-38862] Configurable partition discovery interval in upsert mode by Efrat Levitan · 8 months ago
  68. a90e8f4 [FLINK-38696] Replace custom RateLimiterStrategy with built-in in KafkaSinkITCase (#200) by Martijn Visser · 9 months ago
  69. 3370960 [hotfix] Adjust log properties for CI by Arvid Heise · 10 months ago
  70. e386e7c [hotfix] Avoid parallel usage of KafkaTestBase by Arvid Heise · 10 months ago
  71. 6afe553 [FLINK-38681] Revise threading model in enumerator by Arvid Heise · 10 months ago
  72. 3c6991d [hotfix] Refactor weekly tests to use YAML anchors by Martijn Visser · 10 months ago
  73. 83dbe13 [hotfix] Test PRs against both Flink 2.0.x and Flink 2.1.x by Martijn Visser · 10 months ago
  74. 70117a1 [hotfix] Add Python tests to weekly runs and update to latest Flink minor versions by Martijn Visser · 10 months ago
  75. d10088b [hotfix] Fix Python CI by Martijn Visser · 10 months ago
  76. 2d42d9d [FLINK-38322] Update to Kafka client 4.1.0 by Thomas Cooper · 10 months ago
  77. 88e1997 [FLINK-37650][ci] Enable Stale PR Github action by Thomas Cooper · 10 months ago
  78. 95e3896 [hotfix] Fix misleading log message in setTransactionId by Aleksandr Savonin · 10 months ago
  79. a0a071c [hotfix] Remove redundant env var in KafkaUtil by Aleksandr Savonin · 10 months ago
  80. cb5c5c0 [FLINK-38453] Add full splits to KafkaSourceEnumState by Arvid Heise · 11 months ago
  81. d39c079 [FLINK-38471] Add kafka sql connector as explicit dependency to kafka e2e common by Fabian Paul · 11 months ago
  82. ea0b9ab [FLINK-38451] Stop logging interrupts as ERROR by Arvid Heise · 11 months ago
  83. 032c9dd [FLINK-38289] Update to Flink 2.1 by Thomas Cooper · 1 year ago
  84. ac98345 [FLINK-37583] Upgrade to Kafka 4.0.0 client. by Thomas Cooper · 1 year, 5 months ago
  85. ecedd63 [hotfix] Set version to 5.0-SNAPSHOT by Fabian Paul · 1 year, 1 month ago
  86. 957ee8d [FLINK-38063] Update dependencies by Thomas Cooper · 1 year, 2 months ago
  87. ccccaa8 [FLINK-37983] Update to Kafka client 3.9.1 (#180) by Thomas Cooper · 1 year, 2 months ago
  88. 0455935 [FLINK-37818] Add NoopCommitter for non-EOS by Arvid Heise · 1 year, 4 months ago
  89. a18d7af [FLINK-37818] Move KafkaCommitter to internal by Arvid Heise · 1 year, 4 months ago
  90. 5384ab2 [FLINK-37714][Connector/Kafka] Generate entities in a temporary folder while tests by Sergey Nuyanzin · 1 year, 4 months ago
  91. 89badde [FLINK-36659][docs] Update weekly.yml by Arvid Heise · 1 year, 4 months ago
  92. 2bc999b [FLINK-37644] Enforce precise dependencies + ban offenders by Arvid Heise · 1 year, 5 months ago
  93. e874476 [FLINK-37644] Remove jetbrains annotations by Arvid Heise · 1 year, 5 months ago
  94. 39a1f2b [FLINK-37644] Remove unused code and commons-collection by Arvid Heise · 1 year, 5 months ago
  95. 35de2ce [FLINK-37644] Remove flink-shaded-jackson by Arvid Heise · 1 year, 5 months ago
  96. c1442ea [FLINK-37644] Remove mockito by Arvid Heise · 1 year, 5 months ago
  97. d44f574 [FLINK-37644] Remove guava from prod code by Arvid Heise · 1 year, 5 months ago
  98. 16c8559 [hotfix] Updated NOTICE to 2025 by Arvid Heise · 1 year, 5 months ago
  99. 4606010 [FLINK-37622] Fix KafkaSink in BATCH by Arvid Heise · 1 year, 5 months ago
  100. 2b199b0 [hotfix] Harden KafkaWriterFaultToleranceITCase by Arvid Heise · 1 year, 5 months ago