Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
5206 commits
Select commit Hold shift + click to select a range
732b22d
MINOR: Upgrade log4j to version 2.25.1 (#20132)
MichaelMorrisEst Aug 24, 2025
ecd5b4c
MINOR: enhance DescribeClusterResponse ControllerId description (#20400)
brandboat Aug 24, 2025
f97b95c
KAFKA-19498 Add include argument to ConsumerPerformance tool (#20221)
fvaleri Aug 24, 2025
0242d1c
MINOR: update kraft dynamic voter set doc (#20401)
brandboat Aug 25, 2025
b2c1a0f
KAFKA-18841: Enable to test docker image locally (#19028)
FrankYang0529 Aug 26, 2025
5bbc421
MINOR: update TransactionLog#readTxnRecordValue to initialize Transac…
FrankYang0529 Aug 26, 2025
30ffd42
MINOR: Cleanups in the release scripts (#20308)
mimaison Aug 26, 2025
f621a63
KAFKA-19570: Implement offline migration for streams groups (#20288)
lucasbru Aug 26, 2025
d2f162a
MINOR: kafka-stream-groups.sh should fail quickly if the partition le…
JimmyWang6 Aug 26, 2025
614bc3a
KAFKA-17344: Add empty replica FollowerFetch tests (#16884)
abhijeetk88 Aug 26, 2025
4e0d8c9
MINOR: renamed testAsyncConsumerClassicConsumerSubscribeInvalidTopicC…
kirktrue Aug 26, 2025
71fdab1
MINOR: describeTopics should pass the timeout to the describeCluster …
jim0987795064 Aug 26, 2025
49ee1fb
KAFKA-19632: Handle overlap batch on partition re-assignment (#20395)
apoorvmittal10 Aug 26, 2025
a9b2a6d
MINOR: Optimize the entriesWithoutErrorsPerPartition when errorResult…
m1a2st Aug 26, 2025
08057ea
KAFKA-18600 Cleanup NetworkClient zk related logging (#18644)
m1a2st Aug 26, 2025
5fcbf3d
KAFKA-18853 Add documentation to remind users to use valid LogLevelCo…
JimmyWang6 Aug 27, 2025
8d93d10
KAFKA-17108: Add EarliestPendingUpload offset spec in ListOffsets API…
abhijeetk88 Aug 27, 2025
7ffd693
MINOR: Add example integration test commands to README (#20413)
ezhou413 Aug 27, 2025
c797f85
KAFKA-19642 Replace dynamicPerBrokerConfigs with dynamicDefaultConfig…
jim0987795064 Aug 27, 2025
c5d0ddd
MINOR: Refactored gap window names in share partition (#20411)
apoorvmittal10 Aug 27, 2025
a931f85
KAFKA-19625: Consistency of command-line arguments for verifiable pro…
JimmyWang6 Aug 27, 2025
04518f4
KAFKA-19531 Add an end-to-end integration test for the DLQ feature (#…
sebastienviale Aug 27, 2025
0412be9
KAFKA-19641: Fix flaky RestoreIntegrationTest#shouldInvokeUserDefined…
lucasbru Aug 27, 2025
92fe00e
KAFKA-19497; Topic replay code does not handle creation and deletion …
0xffff-zhiyan Aug 27, 2025
7527a8b
MINOR: Cleanup Connect Module (4/n) (#20389)
sjhajharia Aug 27, 2025
74b2228
MINOR: Add a missing @Test to test case "shouldCallOldImplementationE…
frankvicky Aug 28, 2025
1fc25d8
MINOR: remove arguments from AsyncKafkaConsumerTest.newConsumer() tha…
kirktrue Aug 28, 2025
2cc66f1
MINOR: Remove OffsetsForLeaderEpochRequest unused static field (#20418)
m1a2st Aug 28, 2025
6956417
MINOR: Updated name from messages to records for consistency in share…
apoorvmittal10 Aug 28, 2025
3c378da
KAFKA-19647: Implement integration test for offline migration (#20412)
lucasbru Aug 28, 2025
50009cc
KAFKA-19635: KIP-1147 changes for upgrade.html (#20415)
AndrewJSchofield Aug 28, 2025
e6f3efc
KAFKA-19635: Minor docs tweaks (#20434)
AndrewJSchofield Aug 28, 2025
7eeb5c8
MINOR: Removing incorrect multi threaded state transition tests (#20436)
apoorvmittal10 Aug 29, 2025
c7154b8
MINOR: improve RLMQuotaMetricsTest (#20425)
mjsax Aug 29, 2025
2dd2db7
KAFKA-8350 Fix stack overflow when batch size is larger than cluster …
knoxy5467 Aug 29, 2025
65f789f
KAFKA-19626: KIP-1147 Consistency of command-line arguments for remai…
Yunyung Aug 29, 2025
26fea78
MINOR: Remove default config in creating internal stream topic (#20421)
brandboat Aug 29, 2025
e389484
MINOR: Prepend steams to group configs specific to Kafka Streams grou…
bbejeck Aug 29, 2025
5441f5e
KAFKA-19616 Add compression type and level support to LogCompactionTe…
yunchipang Aug 30, 2025
4f2114a
KAFKA-19645 add a lower bound to num.replica.fetchers (#20414)
DL1231 Aug 31, 2025
342a8e6
MINOR: suppress build warning (#20424)
mjsax Sep 1, 2025
2ba30cc
KAFKA-19574: Improve producer and consumer config files (#20302)
fvaleri Sep 2, 2025
4271fd8
KAFKA-19564: Close Consumer in ConsumerPerformance only after metrics…
kirktrue Sep 3, 2025
dd52058
MINOR: Cleanups in Connect (#20077)
mimaison Sep 3, 2025
8448c28
MINOR: Bump requests from 2.31.0 to 2.32.4 in /tests (#19940)
dependabot[bot] Sep 3, 2025
d226b43
KAFKA-18220: Refactor AsyncConsumerMetrics to not extend KafkaConsume…
ShivsundarR Sep 3, 2025
4b9075b
KAFKA-19653: Improve metavariable names in usage messages (#20438)
AndrewJSchofield Sep 3, 2025
6247fd9
KAFKA-19478 [3/N]: Use heaps to discover the least loaded process (#2…
lucasbru Sep 3, 2025
ef10a52
KAFKA-19011 Improve EndToEndLatency Tool with argument parser and mes…
Rancho-7 Sep 3, 2025
a9bce06
KAFKA-19535 add integration tests for DescribeProducersOptions#broker…
apalan60 Sep 3, 2025
ea5b5fe
KAFKA-19432 Add an ERROR log message if broker.heartbeat.interval.ms …
FrankYang0529 Sep 3, 2025
c3af206
MINOR: code cleanup (#20455)
mjsax Sep 4, 2025
6097b33
MINOR: Update supported image tags in docker_scan (#20459)
mimaison Sep 4, 2025
a81f08d
KAFKA-19550: Integration test for Streams-related Admin APIs [1/N] (#…
lucliu1108 Sep 4, 2025
29b940b
MINOR: Use drainEvents() in ShareConsumerImpl::processBackgroundEvent…
ShivsundarR Sep 4, 2025
6a1cdf8
MINOR: Refactor CLI tools to use CommandLineUtils#maybePrintHelpOrVer…
apalan60 Sep 4, 2025
9257c43
MINOR: Fix failed e2e compatibility_test_new_broker_test and upgrade_…
JimmyWang6 Sep 4, 2025
1d0c5f2
KAFKA-19667: Close ShareConsumer in ShareConsumerPerformance after me…
AndrewJSchofield Sep 4, 2025
37e04ec
KAFKA-19662: Allow resetting offset for unsubscribed topic in kafka-s…
AndrewJSchofield Sep 4, 2025
d68c41d
KAFKA-19666: Clean up integration tests related to state-updater (#20…
shashankhs11 Sep 4, 2025
8076702
MINOR: Add Unit test for `TimingWheel` (#20443)
m1a2st Sep 4, 2025
32c2383
KAFKA-19658 Tweak org.apache.kafka.clients.consumer.OffsetAndMetadata…
DL1231 Sep 4, 2025
b92d47d
MINOR: Update Kafka Streams API broker compatibility table for 4.1 (#…
JimGalasyn Sep 5, 2025
f922ff6
KAFKA-19259: Async consumer fetch intermittent delays on console cons…
kirktrue Sep 5, 2025
29ce961
MINOR; Revert "KAFKA-18681: Created GetReplicaLogInfo RPCs (#19664)" …
josefk31 Sep 5, 2025
af03353
KAFKA-19659: Wrong generic type for UnregisterBrokerOptions (#20490)
brandboat Sep 5, 2025
5fefb16
MINOR: extend consumer close java doc with error handling behaviour (…
lianetm Sep 5, 2025
548fb18
MINOR: Fix typo for the headers.separator cli option (#20489)
lkokhreidze Sep 5, 2025
0a12eaa
KAFKA-19112 Unifying LIST-Type Configuration Validation and Default V…
m1a2st Sep 5, 2025
9ba7dd6
KAFKA-19668: processValue() must be declared as value-changing operat…
mjsax Sep 6, 2025
5e2f54e
MINOR: Cleanup Connect Module (5/n) (#20393)
sjhajharia Sep 6, 2025
52dfe1e
MINOR: Cleanup Raft Module (#20348)
sjhajharia Sep 6, 2025
655cfaa
MINOR: remove System.out in test (#20494)
mjsax Sep 6, 2025
f6f6172
MINOR: update gradle from 8.14.1 to 8.14.3 (#20495)
jim0987795064 Sep 6, 2025
350577d
MINOR: Add doc for external schemas in JSONConverter (#20429)
JimmyWang6 Sep 6, 2025
d6688f8
KAFKA-15983 Kafka-acls should return authorization already done if re…
jack2012aa Sep 6, 2025
3c7f99a
MINOR: Cleanup Server Module (#20180)
sjhajharia Sep 7, 2025
24ea7e0
KAFKA-19666: Remove old restoration codepath from PauseResumeIntegrat…
shashankhs11 Sep 8, 2025
b3eed51
KAFKA-19660: JoinWithIncompleteMetadataIntegrationTest fails in isola…
RaidenE1 Sep 8, 2025
f7593db
KAFKA-19666: Remove old restoration codepath from SmokeTestDriverInte…
shashankhs11 Sep 8, 2025
872647f
KAFKA-19585: Avoid noisy NPE logs when closing consumer after constru…
gensericghiro Sep 8, 2025
aa3a64e
KAFKA-19668: update upgrade docs (#20484)
mjsax Sep 8, 2025
639492c
KAFKA-15307: Kafka Streams configuration docs outdated (#20408)
shashankhs11 Sep 9, 2025
1debe64
MINOR: Rename RecordSnapshotWriter.Builder.setMaxBatchSize to setMaxB…
josefk31 Sep 9, 2025
9c9f144
KAFKA-18061 AddRaftVoter responds with error message "NONE" instead o…
Linsiyuan9 Sep 9, 2025
f6f5b4c
KAFKA-19565: Integration test for Streams-related Admin APIs [2/N] (#…
lucliu1108 Sep 9, 2025
620a01b
KAFKA-19661 [4/N]: Prefer range-style assignment (#20486)
lucasbru Sep 9, 2025
d5e624e
KAFKA-19693: Added PersisterBatch record in Share Partition which inc…
chirag-wadhwa5 Sep 9, 2025
9351270
MINOR: Add 4.1.0 to system tests (#20476)
mimaison Sep 9, 2025
0bc2c6e
MINOR: Move topic creation before consumer creation in testListGroups…
lucliu1108 Sep 9, 2025
45b96cb
MINOR: add the explanation of `null` for DeleteAclsRequest#ResourceNa…
DL1231 Sep 9, 2025
8065d5c
MINOR: Making sure log appender is closed in ShareConsumerImplTest.ja…
gensericghiro Sep 9, 2025
8015c87
KAFKA-19679: Fix NoSuchElementException in oldest open iterator metri…
Nikita-Shupletsov Sep 10, 2025
675552a
KAFKA-19490: Remove usages of distutils in docker scripts (#20178)
FrankYang0529 Sep 10, 2025
1ea221c
MINOR: Add 4.1.0 to core system tests (#20477)
mimaison Sep 10, 2025
32b8e32
MINOR: Add 4.1.0 to streams system tests (#20480)
mimaison Sep 10, 2025
a244565
KAFKA-18708: Move ScramPublisher to metadata module (#20468)
see-quick Sep 10, 2025
709c5fa
KAFKA-19666: Remove old restoration codepath from EosIntegrationTest …
shashankhs11 Sep 10, 2025
3512038
KAFKA-19661 [5/N]: Use below-quota as a condition for standby task as…
lucasbru Sep 10, 2025
ff5025a
KAFKA-19695: Fix bug in redundant offset calculation. (#20516)
smjn Sep 10, 2025
865beb6
MINOR: Remove explicit version list from upgrade.from docs (#20518)
mimaison Sep 10, 2025
8a79ea2
KAFKA-19676 EpochState should override close to avoid throwing IOExce…
JimmyWang6 Sep 11, 2025
dd824a2
KAFKA-19666: Remove old restoration codepath from RestoreIntegrationT…
shashankhs11 Sep 11, 2025
2026833
MINOR: Deflake and improve SmokeTestDriverIntegrationTest (#20509)
lucasbru Sep 12, 2025
54b88f6
MINOR: Refactor on FeaturesPublisher and ScramPublisher (#20522)
see-quick Sep 12, 2025
af2a8db
KAFKA-18105 Fix flaky PlaintextAdminIntegrationTest#testElectPreferre…
jim0987795064 Sep 12, 2025
026710c
MINOR: Update ClusterTestExtensions Javadoc example (#20525)
LoganZhuZzz Sep 12, 2025
962f4ad
KAFKA-19203 Replace `ApiError#exception` by `Error#exception` for Kaf…
jim0987795064 Sep 13, 2025
374bc46
MINOR: Cleanups in ops docs (#20532)
mimaison Sep 14, 2025
a9e5292
MINOR: increase Config change throwable log info to error (#14380)
nicolasguyomar Sep 15, 2025
2fd5483
MINOR: Update on fixing tag description missing in javadoc (#20380)
keemsisi Sep 15, 2025
e1b7699
MINOR: Bump versions in CI (#20497)
yunchipang Sep 15, 2025
749c2d9
KAFKA-19609 Move TransactionLogTest to transaction-coordinator module…
apalan60 Sep 15, 2025
8628d74
KAFKA-19661 [6/N]: Use heaps also on the process-level (#20523)
lucasbru Sep 15, 2025
3fcc0c2
MINOR: Fix an off-by-one issue in ValuesTest (#20520)
WenHsuanYu Sep 15, 2025
caeca09
MINOR: Improve producer docs and add tests around timeout behaviour o…
lianetm Sep 15, 2025
3cbb2a0
MINOR: Small cleanups in clients (#20530)
mimaison Sep 15, 2025
dddb619
MINOR: Move RaftManager interface to raft module (#20366)
Yunyung Sep 16, 2025
daa7aae
KAFKA-19604 Document controller.quorum.auto.join.enable config in upg…
DL1231 Sep 16, 2025
2c34738
KAFKA-19694: Trigger StreamsRebalanceListener in Consumer.close (#20511)
lucasbru Sep 16, 2025
9f657ab
MINOR: Improve consumer rebalance callbacks docs (#20528)
lianetm Sep 16, 2025
b043ca2
KAFKA-19683: Remove dead tests and modify tests in TaskManagerTest [1…
shashankhs11 Sep 16, 2025
8ba41a2
MINOR: Expose internal topic creation errors to the user (#20325)
RaidenE1 Sep 16, 2025
bbbc0cf
MINOR: Fix format in CoordinatorLoaderImpl (#20538)
dajac Sep 17, 2025
3bc50f9
KAFKA-19623: Implement KIP-1147 for console producer/consumer/share-c…
ShivsundarR Sep 17, 2025
9a32a71
KAFKA-19699 improve the documentation of `RecordsToDelete` (#20527)
DL1231 Sep 17, 2025
e647bdc
MINOR : Fix parantheses in console_consumer.py and console_share_cons…
ShivsundarR Sep 18, 2025
04b4a8f
KAFKA-19705: Enable streams rebalance protocol in IQv2 integration te…
RaidenE1 Sep 18, 2025
d6fdbfc
MINOR: Fix typos in CoordinatorRecordTypeGenerator (#20549)
dajac Sep 18, 2025
8c8e93c
MINOR: Remove metrics attribute from ConsumerGroup (#20542)
dajac Sep 18, 2025
dbd2b52
MINOR: Fix format in CoordinatorLoaderImplTest (#20548)
squah-confluent Sep 18, 2025
5ed4a48
MINOR: Tighten up argument descriptions for console CLI tools (#20554)
AndrewJSchofield Sep 19, 2025
b72db2b
MINOR: Delete temporary directories after using them in RaftManagerTe…
ryandielhenn Sep 19, 2025
d067c6c
KAFKA-19716: Clear out coordinator snapshots periodically while loadi…
squah-confluent Sep 19, 2025
cfa0b41
MINOR: Remove metrics attribute from StreamsGroup (#20559)
DL1231 Sep 19, 2025
848e3d0
KAFKA-19722: Adding missing metric assigned-partitions for new consum…
lianetm Sep 19, 2025
57e9f98
KAFKA-19644 Enhance the documentation for producer headers and integr…
Yunyung Sep 20, 2025
c49ab6b
MINOR: Optimize map lookup efficiency with getOrDefault (#20229)
Kguswo Sep 20, 2025
5919762
MINOR: Remove exitMessage.set() call in TopicBasedRemoteLogMetadataMa…
jim0987795064 Sep 20, 2025
07b786e
KAFKA-19681 Improve MetadataShell tool by skipping missing children a…
m1a2st Sep 21, 2025
01fccd3
KAFKA-15186 AppInfo metrics don't contain the client-id (#20493)
m1a2st Sep 21, 2025
a0640f9
KAFKA-18351: Remove top-level version field from docker-compose.yml f…
m1a2st Sep 22, 2025
da6a562
KAFKA-17834: Improvements to Dockerfile (#17554)
m1a2st Sep 22, 2025
f16d1f3
KAFKA-19299: Fix race condition in RemoteIndexCacheTest (#19927)
UladzislauBlok Sep 22, 2025
71efb89
MINOR: fix incorrect offset reset logging (#20558)
mjsax Sep 22, 2025
dbe9d34
KAFKA-19624: Improve consistency of command-line arguments for consum…
aheev Sep 23, 2025
0a48361
KAFKA-19690-Add epoch check before verification guard check to preven…
rreddy-22 Sep 23, 2025
1f7631c
MINOR: Fix StreamsRebalanceListenerInvoker (#20575)
lucasbru Sep 24, 2025
8036e49
KAFKA-17554 Flaky testFutureCompletionOutsidePoll in ConsumerNetworkC…
m1a2st Sep 24, 2025
486b991
KAFKA-18711 Move DelegationTokenPublisher to metadata module (#20475)
see-quick Sep 24, 2025
1e4b8a1
KAFKA-6333: java.awt.headless should not be on commandline (#20044)
abhi-ksolves Sep 24, 2025
55020f9
MINOR: Improve the documentation content for DistributedConfig (#20576)
majialoong Sep 24, 2025
cbea4f6
KAFKA-19546: Rebalance should be triggered by subscription change dur…
dongnuo123 Sep 24, 2025
348e64c
MINOR: Add unit tests for verifying --formatter-property in console t…
ShivsundarR Sep 24, 2025
ac63ce9
KAFKA-19544 Improve `MetadataVersion.fromVersionString()` to take an …
DL1231 Sep 24, 2025
563338c
MINOR: Refactor on DelegationTokenManager follow up with KAFKA-18711 …
see-quick Sep 24, 2025
444ceeb
MINOR: Tidy up the Connect docs (#20531)
mimaison Sep 25, 2025
14917ae
MINOR: Handle envelope response in AutoTopicCreationManager (#20569)
RaidenE1 Sep 25, 2025
97c8c6b
KAFKA-19733 Fix arguments to assertEquals() in clients module (#20586)
sjhajharia Sep 25, 2025
f4e00e9
MINOR: Remove unnecessary check in ReplicaManager (#20588)
DL1231 Sep 25, 2025
857b1e9
KAFKA-19719: --no-initial-controllers should not assume kraft.version…
kevin-wu24 Sep 25, 2025
9e9d2a2
MINOR: fix flaky sys test for static membership (#20594)
lianetm Sep 25, 2025
527467d
KAFKA-18356: Explicitly set up instrumentation for inline mocking (Ja…
m1a2st Sep 26, 2025
ac495f9
MINOR: Clean Javadoc for BrokerReconfigurable interface (#20593)
sjhajharia Sep 26, 2025
fb0518c
KAFKA-19730: StreamsGroupDescribe result is missing topology (#20574)
lucasbru Sep 26, 2025
41611b4
MINOR: Followup KAFKA-19112 document updated (#20492)
m1a2st Sep 28, 2025
d2a6999
MINOR: Cleanup `toString` methods in Storage Module (#20432)
sjhajharia Sep 28, 2025
60ad638
KAFKA-19617: ConsumerPerformance#ConsumerPerfRebListener get corrupte…
DL1231 Sep 28, 2025
7d098cf
KAFKA-17876/ KAFKA-19150 Rename AssignmentsManager and RemoteStorageT…
m1a2st Sep 28, 2025
e27ea8d
KAFKA-19702 Move MetadataVersionConfigValidator and related test code…
DL1231 Sep 28, 2025
c2aeec4
MINOR: Remove logContext arrtibute from StreamsGroup and CoordinatorR…
DL1231 Sep 28, 2025
3c08439
KAFKA-19739 Upgrade commons-validator to 1.10.0 (#20601)
pnagy-cldr Sep 29, 2025
92169b8
KAFKA-19357 AsyncConsumer#close hangs as commitAsync never completes …
Mirai1129 Sep 29, 2025
71c5a42
KAFKA-12506: Strengthen AdjustStreamThreadCountTest with stateful cou…
deepgolani4 Sep 29, 2025
1ebca78
KAFKA-19539: Kafka Streams should also purge internal topics based on…
DL1231 Sep 29, 2025
d1a8212
KAFKA-15873: Filter topics before sorting (#19304)
lorcanj Sep 29, 2025
423330e
KAFKA-19692 improve the docs of "clusterId" for AddRaftVoterOptions a…
LoganZhuZzz Sep 30, 2025
7426629
MINOR: Moving quota test to core directory (#20582)
gensericghiro Oct 1, 2025
0ddc69d
KAFKA-19721: Update streams documentation with KIP-1147 changes (#20606)
Yunyung Oct 1, 2025
7f65b1f
MINOR: Typo in ListShareGroupOffsetsResults javadoc (#20623)
AndrewJSchofield Oct 1, 2025
33cd114
KAFKA-9825 Kafka protocol BNF format should have some way to display …
jack2012aa Oct 2, 2025
8468317
KAFKA-19467; Add a metric for controller thread idleness (#20422)
MahsaSeifikar Oct 2, 2025
28e7803
KAFKA-19744: Move restore time calculation to ChangelogMetadata (#20613)
Nikita-Shupletsov Oct 3, 2025
68f1da8
KAFKA-18185: remove internal.leave.group.on.close config (#19400)
frankvicky Oct 3, 2025
7ddd0d7
KAFKA-19703: Removed versions 2.3 and below from UpgradeFromValues. (…
Nikita-Shupletsov Oct 3, 2025
0dd8471
KAFKA-19748: fix metrics leak in Kafka Streams (#20633)
mjsax Oct 3, 2025
bc2f23b
KAFKA-19750 Address the compileClasspath resolution warnings for the …
brandboat Oct 4, 2025
5736d50
KAFKA-19684 Move Gauge#value to MetricValueProvider (#20543)
majialoong Oct 4, 2025
d76442e
MINOR: Fix a minor copy&paste typo in comments (#20634)
NeatGuyCoding Oct 4, 2025
611f412
MINOR: Enable streams rebalance protocol in EosIntegrationTest (#20592)
RaidenE1 Oct 5, 2025
71a7d85
KAFKA-19431: Ensure consumer and share assignment consistency with su…
squah-confluent Oct 6, 2025
24cad50
MINOR: Adjust the timing for creating connect config (#20612)
majialoong Oct 6, 2025
f68a149
KAFKA-18509 Move StateChangeLogger to server-common module (#20637)
m1a2st Oct 6, 2025
162db13
MINOR: simplify last known elr update (#20629)
CalvinConfluent Oct 6, 2025
2da02d9
KAFKA-19723 Adding consumer rebalance metrics test (#20565)
iit2009060 Oct 6, 2025
f5a87b3
KAFKA-19748: Add a note in docs about memory leak in Kafka Streams 4.…
shashankhs11 Oct 6, 2025
c6bbbbe
KAFKA-19174 Gradle version upgrade 8 -->> 9 (#19513)
dejan2609 Oct 7, 2025
fa2496b
MINOR: skip ci-complete on 4.0 (#20644)
Yunyung Oct 7, 2025
ebae768
KAFKA-18193 Refactor Kafka Streams CloseOptions to Fluent API Style (…
m1a2st Oct 7, 2025
2938c42
KAFKA-19754: Add RPC-level integration test for StreamsGroupDescribeR…
lucliu1108 Oct 7, 2025
4a5aa37
MINOR: Move ReconfigurableQuorumIntegrationTest from core module to s…
jim0987795064 Oct 7, 2025
8a1c619
MINOR: `gradle-versions-plugin` version update: 0.52.0 -->> 0.53.0 (s…
dejan2609 Oct 8, 2025
ede6c90
KAFKA-19664 Support building with Java 25 (LTS release) (#20561)
dejan2609 Oct 8, 2025
efc3773
MINOR: Update all github actions to latest version (#20649)
Yunyung Oct 8, 2025
25de320
KAFKA-19518 Remove the usage of KafkaMetricsGroup(Class<?> klass) (#2…
jim0987795064 Oct 8, 2025
d1b160b
KAFKA-19510: clear pendingTasksToInit on tasks clear. (#20646)
Nikita-Shupletsov Oct 8, 2025
be3e40c
HOTFIX: Fix log level in StateChangeLogger#trace (#20662)
jim0987795064 Oct 9, 2025
9d31928
MINOR: Fix the incorrect package name in the metrics and a typo (#20666)
gongxuanzhang Oct 9, 2025
cedf1c0
KAFKA-19776: Fix log values for previous leader id and epoch (#20671)
gaurav-narula Oct 9, 2025
6ef10ec
MINOR: changed the condition to only check the test topic to reduce t…
Nikita-Shupletsov Oct 9, 2025
1e95d04
KAFKA-19747: Update ClientTelemetryReporter telemetry push error hand…
bbejeck Oct 9, 2025
59f51fb
KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManage…
shashankhs11 Oct 10, 2025
2f260d7
MINOR: auto-topic creation back-off (#20663)
RaidenE1 Oct 10, 2025
90087e4
KAFKA-19776: Fix log values for leader epoch (#20676)
gaurav-narula Oct 10, 2025
cc9702a
MINOR: Remove outdated license header comment in wrapper.gradle (#20678)
yhao3 Oct 10, 2025
128a176
MINOR: README.md manual is changed: `aggregatedJavadoc` task is exten…
dejan2609 Oct 12, 2025
cf3e1fc
MINOR: fix some tasks in build.gradle after Gradle version upgrade 8 …
DL1231 Oct 12, 2025
f7aaf46
KAFKA-19772 enhance the documentation for `Node#isFanced` (#20689)
apalan60 Oct 12, 2025
b1b330e
MINOR: Followup KAFKA-18193 for null check and error message (#20650)
m1a2st Oct 12, 2025
4731c19
MINOR: Fix invocation of TestUtils::waitForCondition (#20687)
gaurav-narula Oct 13, 2025
9f822fc
MINOR: Prevent joint compilation error in core under session keepAliv…
apalan60 Oct 13, 2025
b4fc7ae
MINOR: Improve error handling for StorageTool (#20696)
JimmyWang6 Oct 13, 2025
cf18327
KAFKA-19725: Replace --property with --reader-property in ConsoleProd…
ShivsundarR Oct 14, 2025
225660a
KAFKA-19683: Cleanup and rewrite more tests in TaskManagerTest [3/N] …
shashankhs11 Oct 14, 2025
4cb5f1c
KAFKA-19661: Streams groups sometimes describe as NOT_READY when STAB…
lucasbru Oct 14, 2025
68ac60f
MINOR: Make InternalStreamsBuilder#addGraphNode public (#19816)
Chuckame Oct 15, 2025
44edff4
KAFKA-19537: Improve Exit Code Handling in StreamsGroupCommand (#20293)
joshua2519 Oct 15, 2025
2da83ab
MINOR: Update OffsetResetStrategy Javadoc (#20701)
omkreddy Oct 15, 2025
616b023
KAFKA-19691: Add metrics corresponding to consumer rebalance listener…
RaidenE1 Oct 15, 2025
c58cf1d
KAFKA-19763: Parallel remote reads cause memory leak in broker (#20654)
kamalcph Oct 15, 2025
2a0101a
MINOR: Tidy up comments in MetadataVersion (#20697)
AndrewJSchofield Oct 15, 2025
44481ca
KAFKA-19775: Don't fail if nextOffsetsAndMetadataToBeConsumed is not …
Nikita-Shupletsov Oct 16, 2025
087028c
KAFKA-19795: Mark the minOneMessage as false when delayedRemoteFetch …
kamalcph Oct 16, 2025
388739f
KAFKA-19760: RecordTooLargeExceptions in group coordinator when offse…
izzyharker Oct 16, 2025
abee765
MINOR: build dependecies - version updates (#20656)
dejan2609 Oct 16, 2025
727aae9
MINOR: Improve error message for unsupported metadata version downgra…
brandboat Oct 16, 2025
832c7d6
MINOR: ignore result of "missing build scan" (#20659)
Yunyung Oct 16, 2025
d35324e
MINOR: Mark flaky test on AclMetadataControlManagerTest (#20713)
lianetm Oct 16, 2025
781bc7a
MINOR: Cleanup 'share' from group.coordinator.rebalance.protocols (#2…
elmoctarebnou Oct 16, 2025
3ced942
KAFKA-18710 Move DynamicClientQuotaPublisher to metadata module (#20642)
see-quick Oct 16, 2025
6f4ce76
KAFKA-19479: at_least_once mode in Kafka Streams silently drops messa…
shashankhs11 Oct 16, 2025
2486cf1
KAFKA-19724: Global stream thread should not ignore any exceptions (#…
celikfatih Oct 17, 2025
a605c95
MINOR: Separate share consumer metadata class (#20700)
AndrewJSchofield Oct 17, 2025
8450242
KAFKA-19779: Introduce source topic to subtopology map [2/N] (#20717)
lucasbru Oct 17, 2025
36f17cf
KAFKA-19765: Store the last used assignment configuration in the grou…
lucliu1108 Oct 17, 2025
125cd95
KAFKA-19745: Add support for podman when running system tests (#20546)
see-quick Oct 17, 2025
c38476f
MINOR: Fix typo in KafkaApisTest (#20720)
JimmyWang6 Oct 17, 2025
db1ee63
MINOR: new checksum verification in gradlew (#20658)
joshua2519 Oct 17, 2025
8eacd81
KAFKA-19698 Streams package assertEquals arguments adjustments (#20573)
abhi-ksolves Oct 17, 2025
69dd4c8
KAFKA-19779: Add partitions to offset commit validation [1/N] (#20714)
lucasbru Oct 17, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
The diff you're trying to view is too large. We only load the first 3000 changed files.
56 changes: 27 additions & 29 deletions .asf.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -15,38 +15,36 @@
# specific language governing permissions and limitations
# under the License.

# Enable the next-gen .asf.yaml parser
meta:
nextgen: true

notifications:
commits: [email protected]
issues: [email protected]
commits: [email protected]
issues: [email protected]
pullrequests: [email protected]
jira_options: link label

# This list allows you to trigger builds on pull requests. It can have a maximum of 10 people.
# https://cwiki.apache.org/confluence/pages/viewpage.action?spaceKey=INFRA&title=Git+-+.asf.yaml+features#Git.asf.yamlfeatures-JenkinsPRwhitelisting
jenkins:
github_whitelist:
- gharris1727
- vcrfxia
- divijvaidya
- lucasbru
- yashmayya
- philipnee
- vamossagar12
- clolov
- fvaleri
- andymg3

# This list allows you to triage pull requests. It can have a maximum of 10 people.
# https://cwiki.apache.org/confluence/pages/viewpage.action?spaceKey=INFRA&title=Git+-+.asf.yaml+features#Git.asf.yamlfeatures-AssigningexternalcollaboratorswiththetriageroleonGitHub
# This list allows you to triage pull requests and trigger workflow runs on GitHub Actions. It can have a maximum of 10 collaborators.
# Read more here: https://github.com/apache/infrastructure-asfyaml
github:
collaborators:
- gharris1727
- vcrfxia
- divijvaidya
- lucasbru
- yashmayya
- philipnee
- vamossagar12
- clolov
- fvaleri
- andymg3
- m1a2st
- smjn
- TaiJuWu
- brandboat
- Yunyung
- xijiu
- chirag-wadhwa5
- mingyen066
- ShivsundarR
- Rancho-7
enabled_merge_buttons:
squash: true
squash_commit_message: PR_TITLE_AND_DESC
merge: false
rebase: false

# Disable legacy branch protections. We have manual rulesets which protect trunk
# and our release branches. See INFRA-26603
protected_branches: ~
55 changes: 55 additions & 0 deletions .github/actions/gh-api-approve-run/action.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,55 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
---
name: "Approve Workflow Run"
description: "Approve a Workflow run that has been submitted by a non-committer"
inputs:
gh-token:
description: "The GitHub token for use with the CLI"
required: true
repository:
description: "The GitHub repository"
required: true
default: "apache/kafka"
run_id:
description: "The Workflow Run ID"
required: true
pr_number:
description: "The Pull Request number"
required: true
commit_sha:
description: "The SHA of the commit the run is for"
required: true

runs:
using: "composite"
steps:
- name: Approve Workflow Run
shell: bash
env:
GH_TOKEN: ${{ inputs.gh-token }}
REPO: ${{ inputs.repository }}
RUN_ID: ${{ inputs.run_id }}
PR_NUMBER: ${{ inputs.pr_number }}
COMMIT_SHA: ${{ inputs.commit_sha }}
run: |
echo "Approving workflow run $RUN_ID for PR $PR_NUMBER at SHA $COMMIT_SHA";
gh api --method POST \
-H 'Accept: application/vnd.github+json' \
-H 'X-GitHub-Api-Version: 2022-11-28' \
/repos/$REPO/actions/runs/$RUN_ID/approve
67 changes: 67 additions & 0 deletions .github/actions/gh-api-update-status/action.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,67 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
---
name: "Update Commit Status Check"
description: "Update the status of a commit check using the GH CLI"
inputs:
# Composite actions do not support typed parameters. Everything is treated as a string
# See: https://github.com/actions/runner/issues/2238
gh-token:
description: "The GitHub token for use with the CLI"
required: true
repository:
description: "The GitHub repository"
required: true
default: "apache/kafka"
commit_sha:
description: "The SHA of the commit we are updating"
required: true
url:
description: "The URL of the status check"
required: false
default: ""
description:
description: "The text to display next to the check"
default: ""
required: false
context:
description: "The name of the status check"
required: true
state:
description: "The state of the check. Can be one of: error, failure, pending, success"
required: true

runs:
using: "composite"
steps:
- name: Update Check
shell: bash
env:
GH_TOKEN: ${{ inputs.gh-token }}
REPO: ${{ inputs.repository }}
COMMIT_SHA: ${{ inputs.commit_sha }}
STATE: ${{ inputs.state }}
URL: ${{ inputs.url }}
DESCRIPTION: ${{ inputs.description }}
CONTEXT: ${{ inputs.context }}
run: |
gh api --method POST -H "Accept: application/vnd.github+json" -H "X-GitHub-Api-Version: 2022-11-28" \
/repos/$REPO/statuses/$COMMIT_SHA \
-f "state=$STATE" -f "target_url=$URL" \
-f "description=$DESCRIPTION" \
-f "context=$CONTEXT"
115 changes: 115 additions & 0 deletions .github/actions/run-gradle/action.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,115 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
---
name: "Run Tests with Gradle"
description: "Run specified Gradle test tasks with configuration for timeout and test catalog."
inputs:
# Composite actions do not support typed parameters. Everything is treated as a string
# See: https://github.com/actions/runner/issues/2238
test-task:
description: "The Gradle task name to run."
required: true
test-xml-output:
description: "Output directory for JUnit XML results"
required: true
timeout-minutes:
description: "The timeout for the tests, in minutes."
required: true
test-catalog-path:
description: "The file path of the test catalog file."
required: true
build-scan-artifact-name:
description: "The name to use for archiving the build scan."
required: true
test-retries:
description: "The number of retries for a given test should we allow"
required: true
default: "0"
test-repeat:
description: "The number of times to repeat the integration tests"
required: true
default: "1"
test-verbose:
description: "Enable additional logging by the JUnit infrastructure"
required: true
default: "false"
run-new-tests:
description: "Run tests not present in the given test catalog"
required: true
default: "false"
run-flaky-tests:
description: "Run tests marked as flaky"
required: true
default: "false"

outputs:
gradle-exitcode:
description: "The result of the Gradle test task."
value: ${{ steps.run-tests.outputs.exitcode }}

runs:
using: "composite"
steps:
- name: Run JUnit Tests (${{ inputs.test-task }})
# Gradle flags
# --build-cache: Let Gradle restore the build cache
# --no-scan: Don't attempt to publish the scan yet. We want to archive it first.
# --continue: Keep running even if a test fails
# -PcommitId Prevent the Git SHA being written into the jar files (which breaks caching)
shell: bash
id: run-tests
env:
TIMEOUT_MINUTES: ${{ inputs.timeout-minutes}}
TEST_CATALOG: ${{ inputs.test-catalog-path }}
TEST_TASK: ${{ inputs.test-task }}
TEST_RETRIES: ${{ inputs.test-retries }}
TEST_REPEAT: ${{ inputs.test-repeat }}
RUN_NEW_TESTS: ${{ inputs.run-new-tests }}
RUN_FLAKY_TESTS: ${{ inputs.run-flaky-tests }}
TEST_XML_OUTPUT_DIR: ${{ inputs.test-xml-output }}
TEST_VERBOSE: ${{ inputs.test-verbose }}
# This build step is invoked by build.yml to run junit tests only,
# Spotbugs is being run by that workflow via the "check" task and does not need to also be run here,
# since that is redundant.
run: |
set +e
./.github/scripts/thread-dump.sh &
timeout ${TIMEOUT_MINUTES}m ./gradlew --build-cache --continue --no-scan \
-PtestLoggingEvents=started,passed,skipped,failed \
-PmaxParallelForks=4 \
-PmaxTestRetries=$TEST_RETRIES -PmaxTestRetryFailures=10 \
-Pkafka.test.catalog.file=$TEST_CATALOG \
-Pkafka.test.run.new=$RUN_NEW_TESTS \
-Pkafka.test.run.flaky=$RUN_FLAKY_TESTS \
-Pkafka.test.xml.output.dir=$TEST_XML_OUTPUT_DIR \
-Pkafka.cluster.test.repeat=$TEST_REPEAT \
-Pkafka.test.verbose=$TEST_VERBOSE \
-PcommitId=xxxxxxxxxxxxxxxx \
-x spotbugsMain \
-x spotbugsTest \
$TEST_TASK
exitcode="$?"
echo "exitcode=$exitcode" >> $GITHUB_OUTPUT
- name: Archive build scan (${{ inputs.test-task }})
if: always()
uses: actions/upload-artifact@v4
with:
name: ${{ inputs.build-scan-artifact-name }}
path: ~/.gradle/build-scan-data
compression-level: 9
if-no-files-found: ignore
59 changes: 59 additions & 0 deletions .github/actions/setup-gradle/action.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,59 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
---
name: "Gradle Setup"
description: "Setup Java and Gradle"
inputs:
# Composite actions do not support typed parameters. Everything is treated as a string
# See: https://github.com/actions/runner/issues/2238
java-version:
description: "Java version to use"
default: "17"
gradle-cache-read-only:
description: "Should the Gradle cache be read-only?"
default: "true"
gradle-cache-write-only:
description: "Should the Gradle cache be write-only?"
default: "false"
develocity-access-key:
description: "Optional access key for uploading build scans to Develocity"
default: ""
runs:
using: "composite"
steps:
- name: Setup Java
uses: actions/setup-java@v5
with:
distribution: temurin
java-version: ${{ inputs.java-version }}
- name: Setup Gradle
uses: gradle/actions/setup-gradle@4d9f0ba0025fe599b4ebab900eb7f3a1d93ef4c2 # v5.0.0
env:
GRADLE_BUILD_ACTION_CACHE_DEBUG_ENABLED: true
with:
gradle-version: wrapper
develocity-access-key: ${{ inputs.develocity-access-key }}
develocity-token-expiry: 4
cache-read-only: ${{ inputs.gradle-cache-read-only }}
cache-write-only: ${{ inputs.gradle-cache-write-only }}
# Cache downloaded JDKs in addition to the default directories.
gradle-home-cache-includes: |
caches
notifications
jdks
cache-cleanup: on-success
30 changes: 30 additions & 0 deletions .github/actions/setup-python/action.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,30 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
---
name: "Python Setup"
description: "Setup Python and install dependencies"
runs:
using: "composite"
steps:
- name: Setup Python
uses: actions/setup-python@v6
with:
python-version: 3.12
- name: Pip install
shell: bash
run: pip install -r .github/scripts/requirements.txt
Loading