Skip to content
Open
Show file tree
Hide file tree
Changes from 250 commits
Commits
Show all changes
745 commits
Select commit Hold shift + click to select a range
a6064e0
KAFKA-17607: Add CI step to verify LICENSE-binary (#18299)
xijiu Mar 7, 2025
53b2935
KAFKA-18461 Add Objects.requireNotNull to Snapshot (#18684)
leaf-soba Mar 7, 2025
618ea2c
KAFKA-18285: Add describeStreamsGroup to Admin API (#19116)
lucasbru Mar 7, 2025
d04cdde
MINOR: Allow for configurable delay for periodic tasks (#19143)
kevin-wu24 Mar 7, 2025
8b955b5
MINOR: Wrapping exceptions in usage for groups and metrics utility (#…
apoorvmittal10 Mar 7, 2025
db38bef
KAFKA-18940: fix electionWasClean (#19156)
CalvinConfluent Mar 7, 2025
6940bef
MINOR: Small fit and finish changes to Producer config doc strings (#…
cherylws Mar 7, 2025
343bc99
KAFKA-18920: The kcontrollers must set kraft.version in ApiVersionsRe…
cmccabe Mar 7, 2025
947c414
MINOR: Fix missing argument in kafka-features.sh upgrade doc (#19160)
MahsaSeifikar Mar 7, 2025
adbd282
MINOR: Adjust ToC of zk2kraft and fix wrong section number of docker …
frankvicky Mar 9, 2025
119d043
KAFKA-18700 Migrate SnapshotPath, Entry, OffsetAndEpoch, LogFetchInfo…
mingyen066 Mar 9, 2025
2a0dbd8
KAFKA-18909 Move DynamicThreadPool to server module (#19081)
clarkwtc Mar 9, 2025
1584d49
KAFKA-18944 Remove unused setters from ClusterConfig (#19166)
clarkwtc Mar 9, 2025
a5e5e2d
KAFKA-18706 Move AclPublisher to metadata module (#18802)
FrankYang0529 Mar 9, 2025
d5413fd
KAFKA-17856 Move ConfigCommandTest and ConfigCommandIntegrationTest t…
m1a2st Mar 9, 2025
b129ed4
MINOR: Use immutable KIP link (#19153)
m1a2st Mar 9, 2025
3ebe21c
MINOR: correct user reference in quota configuration from 'userA' to …
Rancho-7 Mar 9, 2025
75260cf
MINOR: Improve grammar and clarity in upgrade.html (#19141)
MahsaSeifikar Mar 10, 2025
832dfa3
KAFKA-18637: Fix max connections per ip and override reconfigurations…
azhar2407 Mar 10, 2025
fc2e3df
MINOR: Disallow unused local variables (#18963)
lucasbru Mar 10, 2025
2723dbf
MINOR: fix add missing @Test lost while rebasing (#19149)
jeqo Mar 10, 2025
806fa5b
MINOR remove legacy branch protections from asf.yaml (#19152)
mumrah Mar 10, 2025
70273fe
HOTFIX fix branch protections in asf.yaml
mumrah Mar 10, 2025
ef29411
KAFKA-18931: added a share group session timeout task when group coor…
chirag-wadhwa5 Mar 10, 2025
19d8a41
KAFKA-15900, KAFKA-18310: fix flaky test testOutdatedCoordinatorAssig…
FrankYang0529 Mar 10, 2025
59e5890
KAFKA-18736: Decide when a heartbeat should be sent (#19121)
cadonna Mar 10, 2025
4dfea3c
MINOR Improve PR linter output (#19159)
mumrah Mar 10, 2025
b8886b8
KAFKA-18941: Do not test 3.3 in upgrade_tests.py (#19162)
josefk31 Mar 11, 2025
bb6d151
MINOR: improve upgrade to v4.0.0 doc (#19172)
showuon Mar 11, 2025
278a93c
KAFKA-18901: [1/N] Improved homogeneous SimpleAssignor (#19142)
AndrewJSchofield Mar 11, 2025
6551e87
KAFKA-18925: Add streams groups support to Admin.listGroups (#19155)
lucasbru Mar 11, 2025
8117617
MINOR: Downgrade log messages of swallowed exception to warnings (#19…
cadonna Mar 11, 2025
52061bf
MINOR: Add documentation to describe default quotas for user and clie…
Rancho-7 Mar 11, 2025
903d70d
MINOR Mark Tls13SelectorTest#testCloseOldestConnection as flaky (#19178)
mumrah Mar 11, 2025
7015733
KAFKA-18933 Add client integration tests module (#19144)
mumrah Mar 11, 2025
a383a95
KAFKA-17808: Fix id typo for connector-dlq-adminclient (#19171)
Yunyung Mar 11, 2025
baa152c
KAFKA-18195: Fix Kafka Streams broker compatibility matrix (#18258)
FrankYang0529 Mar 12, 2025
cf07e6b
KAFKA-18074: Add kafka client compatibility matrix (#18091)
m1a2st Mar 12, 2025
f3da8f5
KAFKA-18936: Fix share fetch when records are larger than max bytes (…
apoorvmittal10 Mar 12, 2025
c07c59a
KAFKA-18932: Removed usage of partition max bytes from share fetch re…
adixitconfluent Mar 12, 2025
d964574
KAFKA-18942: Add reviewers to PR body with committer-tools (#19168)
mingyen066 Mar 12, 2025
f0f7382
KAFKA-18422 Adjust Kafka client upgrade path section (#19119)
mingdaoy Mar 12, 2025
a265328
KAFKA-18837: Ensure controller quorum timeouts and backoffs are at le…
TaiJuWu Mar 12, 2025
e1d980a
MINOR: Remove unused ConfigCommandOptions#forceOpt (#19170)
frankvicky Mar 12, 2025
0ebc3e8
MINOR Mar 12 Flaky tests (#19190)
mumrah Mar 12, 2025
1a18985
KAFKA-18947 Remove unused raftManager in metadataShell (#19169)
mingyen066 Mar 12, 2025
e308068
KAFKA-18142 Switch to `com.gradleup.shadow` (#18018)
dejan2609 Mar 12, 2025
25f8bf8
KAFKA-18617 Allow use of ClusterInstance inside BeforeEach (#18662)
mumrah Mar 12, 2025
55d65cb
MINOR: Cleanups in CoreUtils (#19175)
mimaison Mar 12, 2025
ca834d1
MINOR: remove incorrect deprecated annotations from internal Streams …
aliehsaeedii Mar 13, 2025
759fbbb
KAFKA-14484: Move UnifiedLog to storage module (#19030)
mimaison Mar 13, 2025
d171ff0
KAFKA-18858 Refactor FeatureControlManager to avoid using uninitializ…
FrankYang0529 Mar 13, 2025
2181ddb
KAFKA-18943: Kafka Streams incorrectly commits TX during task revokat…
mjsax Mar 13, 2025
ff785ac
KAFKA-18651: Add Streams-specific broker configurations (#19176)
aliehsaeedii Mar 13, 2025
b2a01b2
MINOR: call the serialize method including headers from the MockProdu…
gklijs Mar 13, 2025
d04efca
KAFKA-18979; Report correct kraft.version in ApiVersions (#19205)
jsancio Mar 13, 2025
049430e
KAFKA-18927 Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0 (#…
Parkerhiphop Mar 14, 2025
5e7445a
KAFKA-17516 Synonyms for client metrics configs (#17264)
AndrewJSchofield Mar 14, 2025
e3800e0
KAFKA-18843: MirrorMaker2 unique workerId (#18994)
k0b3rIT Mar 14, 2025
f50a17f
KAFKA-18606: Flaky test DeleteSegmentsByRetentionTimeTest#executeTier…
m1a2st Mar 14, 2025
c32c167
KAFKA-18781: Extend RefreshRetriableException related exceptions (#19…
k-raina Mar 14, 2025
93499df
KAFKA-18924 Running the storage module tests produces a storage/stora…
m1a2st Mar 14, 2025
e05b0e6
KAFKA-18915 Rewrite AdminClientRebootstrapTest to cover the current s…
clarkwtc Mar 15, 2025
1d0333f
KAFKA-18703 Remove unused class PayloadKeyType (#19129)
mingdaoy Mar 15, 2025
efa6f7f
KAFKA-18993 Remove confusing notable change section from upgrade.html…
frankvicky Mar 15, 2025
7bff678
KAFKA-18859 honor the error message of UnregisterBrokerResponse (#19027)
m1a2st Mar 15, 2025
766caaa
MINOR: Clean up metadata module (#19069)
sjhajharia Mar 15, 2025
f7d07d6
KAFKA-18990 Avoid redundant MetricName creation in BaseQuotaTest#prod…
mingyen066 Mar 16, 2025
a7e40b7
KAFKA-18736: Do not send fields if not needed (#19181)
cadonna Mar 16, 2025
da46cf6
KAFKA-17565 Move MetadataCache interface to metadata module (#18801)
FrankYang0529 Mar 17, 2025
a6a0ea5
KAFKA-17171 Add test cases for `STATIC_BROKER_CONFIG`in kraft mode (#…
frankvicky Mar 17, 2025
ec3c319
MINOR: Rewrite unchecked operations in Mock API (#19071)
clarkwtc Mar 17, 2025
e9ffe0b
KAFKA-18808 add test to ensure the name=<default> is not equal to def…
Rancho-7 Mar 17, 2025
0ce87e7
KAFKA-18955: Fix infinite loop and standardize options in MetadataSch…
ahuang98 Mar 17, 2025
b805877
KAFKA-18969 Rewrite ShareConsumerTest#setup and move to clients-integ…
m1a2st Mar 18, 2025
806aa55
MINOR: Update docker_scan.yml with 4.0.0 (#19225)
dajac Mar 18, 2025
bb24d85
MINOR Fixup develocity report (#19179)
mumrah Mar 18, 2025
3ed5902
MINOR: Add 4.0.0 to deps (#19229)
dajac Mar 18, 2025
a5325e0
KAFKA-17431: Support invalid static configs for KRaft so long as dyna…
kevin-wu24 Mar 18, 2025
3a3159b
KAFKA-18953: [1/N] Add broker side handling for 2 PC (KIP-939) (#19193)
rreddy-22 Mar 19, 2025
fcca405
KAFKA-18975 Move clients-integration-test out of core module (#19217)
FrankYang0529 Mar 19, 2025
e73719d
KAFKA-18819 StreamsGroupHeartbeat API and StreamsGroupDescribe API c…
DL1231 Mar 19, 2025
31e1a57
KAFKA-18989 Optimize FileRecord#searchForOffsetWithSize (#19214)
m1a2st Mar 20, 2025
b83a23a
KAFKA-18946 Move BrokerReconfigurable and DynamicProducerStateManager…
frankvicky Mar 20, 2025
573b31d
MINOR: Add 4.0.0 to core system tests (#19238)
dajac Mar 20, 2025
804bf59
KAFKA-18329; [1/3] Delete old group coordinator (KIP-848) (#19243)
dajac Mar 20, 2025
f24945b
KAFKA-15931: Cancel RemoteLogReader gracefully (#19197)
jeqo Mar 20, 2025
71875ec
KAFKA-18845: Fix flaky QuorumControllerTest#testUncleanShutdownBroker…
FrankYang0529 Mar 20, 2025
1c582a4
KAFKA-18954: Add ELR election rate metric (#19180)
CalvinConfluent Mar 20, 2025
121ec2a
KAFKA-15599 Move MetadataLogConfig to raft module (#19246)
mimaison Mar 21, 2025
0548f1b
KAFKA-19017: Changed consumer.config to command-config in verifiable_…
chirag-wadhwa5 Mar 21, 2025
e21c46a
MINOR: Move FileRecord JavaDoc to comment (#19257)
m1a2st Mar 21, 2025
1ded681
MINOR: Add 4.0.0 to streams system tests (#19239)
dajac Mar 21, 2025
0c5e5c5
KAFKA-18329; [2/3] Delete old group coordinator (KIP-848) (#19251)
dajac Mar 21, 2025
8fa3856
MINOR Mar 19 flaky tests (#19248)
mumrah Mar 21, 2025
79fe130
KAFKA-18893: Add KIP-877 support to ReplicaSelector (#19064)
TaiJuWu Mar 21, 2025
ca20e9c
KAFKA-18329; [3/3] Delete old group coordinator (KIP-848) (#19255)
dajac Mar 21, 2025
ec12d36
MINOR: Move inner test classes out of CoordinatorRuntimeTest (#19258)
squah-confluent Mar 21, 2025
1260b6d
KAFKA-17806 remove this-escape suppress warnings in AclCommand (#19256)
FrankYang0529 Mar 21, 2025
68ecb77
MINOR: add log4j2.yaml to clients-integration-tests module (#19252)
m1a2st Mar 21, 2025
d497250
KAFKA-18999 Remove BrokerMetadata (#19227)
FrankYang0529 Mar 22, 2025
5d2bfb4
KAFKA-18980 OffsetMetadataManager#cleanupExpiredOffsets should record…
Rancho-7 Mar 22, 2025
fef9aeb
KAFKA-18276 Migrate ProducerRebootstrapTest to new test infra (#19046)
clarkwtc Mar 23, 2025
a524fc6
MINOR: leverage preProcessParsedConfig within AbstractConfig (#19259)
TaiJuWu Mar 23, 2025
82de719
MINOR; Improve error message for the storage format command (#19210)
jsancio Mar 23, 2025
b5f5265
KAFKA-18796: Added more information to error message when assertion f…
chirag-wadhwa5 Mar 24, 2025
b7728d9
KAFKA-18984: Reset interval.ms By Using kafka-client-metrics.sh (#19213)
Parkerhiphop Mar 24, 2025
95ef344
MINOR: FindCoordinator API should return INVALID_REQUEST when share p…
dajac Mar 24, 2025
20bad6e
KAFKA-18576 Convert ConfigType to Enum (#18711)
frankvicky Mar 24, 2025
15474e0
MINOR: Cleanup Server Common Module (#19085)
sjhajharia Mar 24, 2025
9db5888
MINOR: FindCoordinator API does not lookup partition for share partit…
dajac Mar 24, 2025
266532f
KAFKA-18736: Handle errors in the Streams group heartbeat request man…
cadonna Mar 24, 2025
96196bb
KAFKA-18736: Add pollOnClose() and maximumTimeToWait() (#19233)
cadonna Mar 25, 2025
62f923a
MINOR: Update .asf.yaml collaborators (#19280)
mimaison Mar 25, 2025
9992e4c
MINOR: Move record helper methods out of CoordinatorRuntimeTest (#19279)
squah-confluent Mar 25, 2025
8c3f16d
MINOR: add missing link for KIP-1104 (#19271)
FrankYang0529 Mar 25, 2025
80d99ea
KAFKA-18991: FetcherThread should match leader epochs between fetch r…
frankvicky Mar 25, 2025
1547204
KAFKA-18914 Migrate ConsumerRebootstrapTest to use new test infra (#1…
clarkwtc Mar 25, 2025
91758cc
KAFKA-18899: Improve handling of timeouts for commitAsync() in ShareC…
ShivsundarR Mar 26, 2025
b6adec4
KAFKA-18616; Refactor Tools's ApiMessageFormatter (#18695)
dajac Mar 26, 2025
56d1dc1
MINOR: Use readable interface to parse requests (#19163)
soondenana Mar 26, 2025
eb88e78
KAFKA-18827: Initialize share group state group coordinator impl. [3/…
smjn Mar 26, 2025
84b8fec
KAFKA-14486 Move LogCleanerManager to storage module (#19216)
wernerdv Mar 27, 2025
b9d5597
KAFKA-17830 Cover unit tests for TBRLMM init failure scenarios (#19076)
FrankYang0529 Mar 27, 2025
b952ea4
MINOR: Remove stray printStackTrace from RequestConvertToJsonTest (#1…
ijuma Mar 27, 2025
9e42b76
MINOR: Some cleanups in group coordinator's intergration tests (#19281)
dajac Mar 27, 2025
2267902
MINOR: Mark streams RPCs as unstable (#19292)
lucasbru Mar 27, 2025
28de78b
MINOR: Refactor GroupCoordinator write path (#19290)
dajac Mar 27, 2025
9292a22
KAFKA-19049 Remove the `@ExtendWith(ClusterTestExtensions.class)` fro…
Rancho-7 Mar 28, 2025
c125cc7
KAFKA-19036 Rewrite LogAppendTimeTest and move it to storage module (…
FrankYang0529 Mar 28, 2025
c771116
KAFKA-19005 improve the documentation of DescribeTopicsOptions#partit…
Rancho-7 Mar 28, 2025
4a5ae14
KAFKA-19032 Remove TestInfoUtils.TestWithParameterizedQuorumAndGroupP…
FrankYang0529 Mar 29, 2025
c095faa
KAFKA-18945 Enhance the docs for Admin APIs (#19315)
brandboat Mar 31, 2025
4144290
MINOR: Cleanup metadata module (#18937)
wernerdv Mar 31, 2025
6d72677
KAFKA-18613: Add StreamsGroupHeartbeat handler in the group coordinat…
lucasbru Mar 31, 2025
c5f8ae0
KAFKA-16260: Deprecate window.size.ms and window.inner.class.serde in…
FrankYang0529 Mar 31, 2025
2054693
KAFKA-19042 Move ConsumerTopicCreationTest to client-integration-test…
frankvicky Mar 31, 2025
8b80626
KAFKA-18959 increase the num_workers from 9 to 14 (#19274)
apalan60 Mar 31, 2025
d038f44
MINOR: Small cleanups in ReplicaManager (#19322)
dajac Mar 31, 2025
5982943
KAFKA-18409: ShareGroupStateMessageFormatter should use CoordinatorRe…
brandboat Mar 31, 2025
b375bb0
MINOR: Remove unused `ApiKeys.minRequiredInterBrokerMagic` (#19325)
ijuma Mar 31, 2025
6f4d425
KAFKA-18613: Improve test coverage for missing topics (#19189)
lucasbru Mar 31, 2025
e380968
KAFKA-18613: Unit tests for usage of incorrect RPCs (#18383)
lucasbru Apr 1, 2025
4aa8120
KAFKA-19018,KAFKA-19063: Implement maxRecords and acquisition lock ti…
apoorvmittal10 Apr 1, 2025
ed77397
KAFKA-19062: Port changes from KAFKA-18645 to share-consumers (#19335)
ShivsundarR Apr 1, 2025
7ee73e6
MINOR: Accept Throwables in DeferredEventQueue.failAll (#19337)
squah-confluent Apr 1, 2025
0c97338
KAFKA-18796-2: Corrected the check for acquisition lock timeout in Sh…
chirag-wadhwa5 Apr 1, 2025
e301508
MINOR: Add check in ShareConsumerImpl to send acknowledgements of con…
ShivsundarR Apr 1, 2025
ccf2510
MINOR: Remove dead code `maybeWarnIfOversizedRecords` (#19316)
ijuma Apr 1, 2025
1eea7f0
MINOR: Make coordinator runtime inner classes static (#19332)
squah-confluent Apr 1, 2025
cee55db
KAFKA-18794: Disable flaky tests pending investigation (#19340)
AndrewJSchofield Apr 1, 2025
e3430fe
KAFKA-19072: Add system test for ELR (#19344)
CalvinConfluent Apr 1, 2025
793b470
KAFKA-19016: Updated the retention behaviour of share groups to retai…
chirag-wadhwa5 Apr 2, 2025
87a299a
KAFKA-18826: Add global thread metrics (#18953)
bbejeck Apr 2, 2025
75f384a
MINOR: Cleanup Raft Module (#19284)
sjhajharia Apr 2, 2025
2994e5e
KAFKA-19004 Move DelayedDeleteRecords to server-common module (#19226)
gongxuanzhang Apr 2, 2025
eeffd8c
KAFKA-19003: Add forceTerminateTransaction command to CLI tools (#19276)
rreddy-22 Apr 2, 2025
d619cc5
KAFKA-19058 Running the streams/streams-scala module tests produces a…
m1a2st Apr 2, 2025
5c01fd0
KAFKA-18949 add consumer protocol to testDeleteRecordsAfterCorruptRec…
FrankYang0529 Apr 3, 2025
be80e3c
KAFKA-18923: resource leak in RSM fetchIndex inputStream (#19111)
FrankYang0529 Apr 3, 2025
37f7434
KAFKA-18827: Incorporate initializing topics in share group heartbeat…
smjn Apr 3, 2025
6ef42d1
MINOR: Deduplicate topics of a topology for authorization check (#19352)
cadonna Apr 3, 2025
d7fa406
KAFKA-19064: Handle exceptions from deferred events in coordinator (#…
squah-confluent Apr 3, 2025
c3f0890
KAFKA-19075: Included other share group dynamic configs in extractSha…
chirag-wadhwa5 Apr 3, 2025
f1bb29b
MINOR: migrate BrokerCompressionTest to storage module (#19277)
TaiJuWu Apr 3, 2025
db4e74b
MINOR: Add Functional Interface annotation to interfaces used by Lamb…
Tombert Apr 3, 2025
03b1b72
MINOR: Cleanup Storage Module (#19072)
sjhajharia Apr 3, 2025
6f92896
MINOR: Cleanup test-common-runtime module (#19305)
frankvicky Apr 3, 2025
a437504
KAFKA-19055 Cleanup the 0.10.x information from clients module (#19320)
LoganZhuZzz Apr 3, 2025
5eb4e11
KAFKA-18067: Add a flag to disable producer reset during active task …
frankvicky Apr 3, 2025
d35ab4d
KAFKA-18713: Fix FK Left-Join result race condition (#19005)
nilmadhab Apr 3, 2025
98c0f30
MINOR: Added trace logs to help debug SharePartition (#19358)
adixitconfluent Apr 4, 2025
d4d9f11
KAFKA-18761: [2/N] List share group offsets with state and auth (#19328)
AndrewJSchofield Apr 4, 2025
36c2fac
MINOR: Consider repartition source topic for changelog topics (#19373)
cadonna Apr 4, 2025
25f9b1e
MINOR: ShutdownableThread: log on error level on FatalExitError (#19351)
gaurav-narula Apr 4, 2025
cd49634
MINOR: Rename streams group configs for consistency with other config…
aliehsaeedii Apr 4, 2025
ef73fb9
MINOR: Remove DeleteSegmentsByRetentionTimeTest#executeTieredStorageT…
m1a2st Apr 4, 2025
6af849f
KAFKA-7952: use in memory stores for KTable test (#19218)
lorcanj Apr 4, 2025
30c511d
KAFKA-19085: SharePartitionManagerTest testMultipleConcurrentShareFet…
adixitconfluent Apr 4, 2025
d6ff7b8
KAFKA-13747: refactor TopologyTest to test different store type param…
FrankYang0529 Apr 4, 2025
08a93fe
KAFKA-14523: Move DelayedRemoteListOffsets to the storage module (#19…
mimaison Apr 5, 2025
ebb6281
KAFKA-19074 Remove the cached responseData from ShareFetchResponse (#…
TaiJuWu Apr 5, 2025
3d96b20
KAFKA-19042 Move TransactionsExpirationTest to client-integration-tes…
FrankYang0529 Apr 5, 2025
3f0e14a
MINOR: rename metric variable name in Processor#accept (#19361)
gaurav-narula Apr 5, 2025
8c77953
MINOR: Revert "migrate LogFetchInfo, Assignment and RequestAndComplet…
mingyen066 Apr 5, 2025
3f8e86a
KAFKA-19013 Reformat PR body to 72 characters (#19242)
mumrah Apr 5, 2025
b963e58
KAFKA-16407: Fix foreign key INNER join on change of FK from/to a nul…
AyoubOm Apr 6, 2025
74acbd2
KAFKA-16758: Extend Consumer#close with an option to leave the group …
frankvicky Apr 6, 2025
ab4a0f0
MINOR: small optimization by judgment (#19386)
gongxuanzhang Apr 6, 2025
9f676dd
MINOR: Clean up unreachable code in FetcherTest (#19376)
Parkerhiphop Apr 6, 2025
a65626b
MINOR: Add functionalinterface to the producer callback (#19366)
Tombert Apr 6, 2025
e69a311
KAFKA-19076 replace `String` by `Supplier<String>` for UnifiedLog#may…
Rancho-7 Apr 6, 2025
6d68f8a
MINOR: Move BrokerReconfigurable to the sever-common module (#19383)
frankvicky Apr 6, 2025
6dd2cc7
MINOR: Clean up comments and remove unused code in RecordVersion and …
apalan60 Apr 6, 2025
563f347
KAFKA-18894: Add KIP-877 support for ConfigProvider
Yunyung Apr 7, 2025
2d02f1d
KAFKA-19084: Port KAFKA-16224, KAFKA-16764 for ShareConsumers (#19369)
ShivsundarR Apr 7, 2025
2a05c0c
KAFKA-19001: Use streams group-level configurations in heartbeat (#19…
lucasbru Apr 7, 2025
391b258
KAFKA-19077: Propagate shutdownRequested field (#19359)
lucasbru Apr 7, 2025
2ae4ffb
MINOR: Cleanup Core Module (#19372)
sjhajharia Apr 7, 2025
b8c0950
MINOR: Rename RemoteLogStorageManager variable to RemoteStorageManage…
stanislavkozlovski Apr 7, 2025
fcf6da0
KAFKA-19098 Remove `lastOffset` from PartitionResponse (#19398)
Rancho-7 Apr 7, 2025
08dff59
spotlessApply
Yunyung Apr 7, 2025
9e221e3
Update msg in Utils.closeQuietly
Yunyung Apr 7, 2025
1dd8f41
Add a test to verify withPluginMetrics is called after configure
Yunyung Apr 7, 2025
204c8a9
Refactor the test
Yunyung Apr 7, 2025
96fd5a6
Refactor
Yunyung Apr 7, 2025
6ef4001
Add a newline at the end of the file
Yunyung Apr 7, 2025
44ecfdb
Fix NPE in transform method
Yunyung Apr 8, 2025
e26a06f
Remove debug print
Yunyung Apr 8, 2025
e2d472d
MINOR: Minor tidying in GroupMetadataManager (#19411)
AndrewJSchofield Apr 8, 2025
6c2af5f
MINOR: Small cleanups in server tests (#19395)
wernerdv Apr 8, 2025
375ed19
KAFKA-19100: Use ProcessRole instead of String in AclApis (#19406)
gongxuanzhang Apr 8, 2025
9a2b8b6
MINOR: Move DelayedRecords purgatory classes to server (#19408)
gongxuanzhang Apr 8, 2025
2f086d1
KAFKA-18892: Add KIP-877 support for ClientQuotaCallback (#19068)
m1a2st Apr 8, 2025
a4ea5df
KAFKA-19099 Remove GroupSyncKey, GroupJoinKey, and MemberKey (#19413)
Rancho-7 Apr 8, 2025
dcf6f9d
MINOR: remove unused function BrokerRegistration#isMigratingZkBroker …
FrankYang0529 Apr 8, 2025
434b0d3
MINOR: use enum map for error counts map (#19314)
lorcanj Apr 8, 2025
6e446f0
KAFKA-19047: Allow quickly re-registering brokers that are in control…
ahuang98 Apr 8, 2025
d7ad625
MINOR Fix PR Linter "Reviewers" handling (#19415)
mumrah Apr 8, 2025
dc172f3
MINOR: remove transform and through from repartition description (#19…
FrankYang0529 Apr 9, 2025
43e22ef
KAFKA-19093 Change the "Handler on Broker" to "Handler on Controller"…
Rancho-7 Apr 9, 2025
5148174
KAFKA-16718-2/n: KafkaAdminClient and GroupCoordinator implementation…
chirag-wadhwa5 Apr 9, 2025
56591d2
KAFKA-19090: Move DelayedFuture and DelayedFuturePurgatory to server …
FrankYang0529 Apr 9, 2025
2a370ed
KAFKA-19037: Integrate consumer-side code with Streams (#19377)
cadonna Apr 9, 2025
fa62bce
KAFKA-18287: Add support for kafka-streams-groups.sh --list (#19422)
aliehsaeedii Apr 9, 2025
eeb1214
KAFKA-18962: Fix onBatchRestored call in GlobalStateManagerImpl (#19188)
fhussonnois Apr 9, 2025
699ae1b
KAFKA-16729: Support isolation level for share consumer (#19261)
adixitconfluent Apr 10, 2025
6430fb5
MINOR: Add note that streams groups are in early access (#19434)
lucasbru Apr 10, 2025
b649b1e
KAFKA-18935: Ensure brokers do not return null records in FetchRespon…
frankvicky Apr 10, 2025
42799f7
MINOR update the README docker image version (#19278)
m1a2st Apr 10, 2025
c3b7aa6
KAFKA-18170: Add create and write timestamp fields in share snapshot …
smjn Apr 10, 2025
c65a161
KAFKA-19118: Enable KIP-1071 in InternalTopicIntegrationTest (#19425)
lucasbru Apr 10, 2025
c11938c
KAFKA-19124: Use consumer background event queue for Streams events (…
cadonna Apr 10, 2025
a6dfde7
KAFKA-18629: Utilize share group partition metadata for delete group.…
smjn Apr 10, 2025
b3ba7bc
KAFKA-18782: Extend ApplicationRecoverableException related exception…
k-raina Apr 10, 2025
90e7b53
MINOR: Remove unused `ApiVersions` variable from Sender and RecordAcc…
Yunyung Apr 11, 2025
588d107
KAFKA-19101 Remove ControllerMutationQuotaManager#throttleTimeMs unus…
m1a2st Apr 11, 2025
34a87d3
KAFKA-19042 Move TransactionsWithMaxInFlightOneTest to client-integra…
FrankYang0529 Apr 11, 2025
99f871a
MINOR: Consolidated message formatter for share group records (#19435)
AndrewJSchofield Apr 11, 2025
3623726
KAFKA-18286: Implement support for streams groups in kafka-groups.sh …
lucasbru Apr 11, 2025
9e62028
KAFKA-19118: Enable KIP-1071 in StandbyTaskCreationIntegrationTest (#…
lucasbru Apr 11, 2025
bc6f4ea
KAFKA-19103 Remove OffsetConfig (#19441)
yunchipang Apr 11, 2025
3e0276e
KAFKA-19127: Integration test for altering and describing streams gro…
aliehsaeedii Apr 11, 2025
21a080f
KAFKA-16894: Define feature to enable share groups (#19293)
AndrewJSchofield Apr 11, 2025
88a6402
MINOR: Update kafka-console-share-consumer to pass in delivery count.…
ShivsundarR Apr 11, 2025
23cfb98
MINOR VerifableProducer ducktape can set idempotency and retries (#19…
josefk31 Apr 11, 2025
7863b35
KAFKA-14485: Move LogCleaner to storage module (#19387)
wernerdv Apr 11, 2025
27d9a55
Merge branch 'trunk' into KAFKA-18894
Yunyung Apr 12, 2025
b92a2bb
Address m1a2st comments
Yunyung Apr 12, 2025
5989a26
Update Vagrantfile
DDShantanuBadmanji Oct 1, 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
  •  
  •  
  •  
31 changes: 22 additions & 9 deletions .asf.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,10 @@
# 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]
Expand All @@ -25,13 +29,22 @@ notifications:
# Read more here: https://github.com/apache/infrastructure-asfyaml
github:
collaborators:
- FrankYang0529
- kirktrue
- brandboat
- AndrewJSchofield
- OmniaGM
- nizhikov
- dongnuo123
- gaurav-narula
- apourchet
- apoorvmittal10
- brandboat
- frankvicky
- FrankYang0529
- gongxuanzhang
- m1a2st
- mingyen066
- smjn
- TaiJuWu
- xijiu
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: ~
45 changes: 40 additions & 5 deletions .github/actions/run-gradle/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,10 @@ 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 test suite to run. Either 'test' or 'quarantinedTest'."
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."
Expand All @@ -33,10 +36,32 @@ inputs:
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:
Expand All @@ -52,15 +77,25 @@ runs:
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 }}
run: |
set +e
./.github/scripts/thread-dump.sh &
timeout ${TIMEOUT_MINUTES}m ./gradlew --build-cache --continue --no-scan \
-PtestLoggingEvents=started,passed,skipped,failed \
-PmaxParallelForks=2 \
-PmaxTestRetries=1 -PmaxTestRetryFailures=3 \
-PmaxQuarantineTestRetries=3 -PmaxQuarantineTestRetryFailures=0 \
-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 \
$TEST_TASK
exitcode="$?"
Expand All @@ -72,4 +107,4 @@ runs:
name: ${{ inputs.build-scan-artifact-name }}
path: ~/.gradle/build-scan-data
compression-level: 9
if-no-files-found: ignore
if-no-files-found: ignore
2 changes: 1 addition & 1 deletion .github/actions/setup-gradle/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ runs:
distribution: temurin
java-version: ${{ inputs.java-version }}
- name: Setup Gradle
uses: gradle/actions/setup-gradle@d156388eb19639ec20ade50009f3d199ce1e2808 # v4.1.0
uses: gradle/actions/setup-gradle@94baf225fe0a508e581a564467443d0e2379123b # v4.3.0
env:
GRADLE_BUILD_ACTION_CACHE_DEBUG_ENABLED: true
with:
Expand Down
11 changes: 11 additions & 0 deletions .github/pull_request_template.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
Delete this text and replace it with a detailed description of your change. The
PR title and body will become the squashed commit message.

If you would like to tag individuals, add some commentary, upload images, or
include other supplemental information that should not be part of the eventual
commit message, please use a separate comment.

If applicable, please include a summary of the testing strategy (including
rationale) for the proposed change. Unit and/or integration tests are expected
for any behavior change and system tests should be considered for larger
changes.
Loading
Loading