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