Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
758 commits
Select commit Hold shift + click to select a range
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
bc63bef
MINOR: Add Javadoc for handleAddVoterRequest, handleRemoveVoterReques…
LoganZhuZzz Oct 18, 2025
1660289
KAFKA-19792 Gradle build fails after Swagger patch version update (#2…
brandboat Oct 18, 2025
e00be57
KAFKA-19771 Update SpotBugs version and enable Spotbugs Gradle tasks …
dejan2609 Oct 19, 2025
10f26c8
KAFKA-18836: KIP-1136 annotate constructors in ConsumerGroupMetadata …
pszymczyk Oct 20, 2025
618c87b
MINOR: Suppress warning logs for UnsupportedVersionException in Clien…
DL1231 Oct 20, 2025
f3494aa
MINOR: A few more annotations for removal deprecation in tests (#20731)
AndrewJSchofield Oct 20, 2025
18dc54a
MINOR: scala coverage plugin upgrade: 2.3.0 -->> 2.4.0 (version teste…
dejan2609 Oct 20, 2025
35bd71c
MINOR: Correct ShareGroupAssignmentBuilder#filterAssignedPartitions t…
majialoong Oct 20, 2025
cc4986e
MINOR: Correcting the order of params in share fetch/partition tests …
apoorvmittal10 Oct 20, 2025
c53c571
MINOR: Makes `LogCleaner.CleanerThread` a `final` class. (#20660)
see-quick Oct 20, 2025
92d9dc1
KAFKA-19758: Preferably use the connector classloader when loading pl…
mimaison Oct 20, 2025
4bf65a7
MINOR: fixed fail_many_brokers behavior if failure mode is not clean_…
Nikita-Shupletsov Oct 20, 2025
8dfaedd
MINOR: Mark`org.apache.kafka.streams.integration.EosIntegrationTest.s…
ezhou413 Oct 21, 2025
25aae99
KAFKA-19808: Handle batch alignment when share partition is at capaci…
apoorvmittal10 Oct 21, 2025
05999c7
KAFKA-19746 : Tools | Fix order of arguments to assertEquals in unit …
samarth-ksolves Oct 21, 2025
32dedbd
MINOR: Update the delayed remote fetch purgatory cleanup comment (#20…
kamalcph Oct 22, 2025
2baad13
KAFKA-19521: Fix consumption and leaving group when source topic is d…
RaidenE1 Oct 22, 2025
8c794fc
KAFKA-19821 Duplicated batches should be logged (#20740)
brandboat Oct 22, 2025
6f1bd8f
KAFKA-18973 gracefully stopping test execution if .git does not exis…
iit2009060 Oct 22, 2025
61587ed
MINOR: simplify FK-join logic (#20605)
mjsax Oct 22, 2025
2c44448
MINOR: Upgrade release.py to run with JDK 25 (#20699)
apalan60 Oct 22, 2025
f2ce4dc
MINOR: Enhance reportCoverage docs with coverage report output paths …
mingyen066 Oct 23, 2025
53c8fab
KAFKA-19767: Add partitions to share fetch buffer together (#20737)
AndrewJSchofield Oct 23, 2025
6d16f68
KAFKA-19662: Reset share group offsets for unsubscribed topics (#20708)
AndrewJSchofield Oct 23, 2025
87657fd
KAFKA-19827: Call ack commit callback at end of waiting calls (#20758)
AndrewJSchofield Oct 24, 2025
4768585
MINOR: Update Jackson to the latest patch (#20761)
fvaleri Oct 24, 2025
76a1c83
KAFKA-19340 Move DelayedRemoteFetch to the storage module (#19876)
DL1231 Oct 24, 2025
82a1935
MINOR: Fix time comparison with appendLingerMs in CoordinatorRuntime#…
majialoong Oct 24, 2025
23d6764
MINOR: Improve some requests/responses toString method (#20759)
showuon Oct 25, 2025
bb0b62d
KAFKA-19803: Implemented support for allow.os.group.write.access conf…
Nikita-Shupletsov Oct 25, 2025
dbe0fda
MINOR: Consistently apply timeout in group commands (#20764)
lucasbru Oct 26, 2025
7a8dba3
KAFKA-19784: KIP-1227: Expose rack ID in MemberDescription and ShareM…
jiafu1115 Oct 27, 2025
6b187e9
KAFKA-16926: Optimize BeginQuorumEpoch heartbeat (#20318)
TaiJuWu Oct 27, 2025
b065c60
KAFKA-19734 Adding application tag to clientstate metric (#20766)
gensericghiro Oct 27, 2025
0a003d0
KAFKA-19823: PartitionMaxBytesStrategy bug when request bytes is less…
adixitconfluent Oct 27, 2025
a395d06
KAFKA-19824: New AllowlistConnectorClientConfigOverridePolicy (KIP-11…
mimaison Oct 28, 2025
7337631
MINOR: Disable testShareGroupMaxSizeConfigExceeded and mark testAckno…
sjhajharia Oct 28, 2025
d6728d4
KAFKA-19789: Log an error when we get duplicate acquired offsets in S…
ShivsundarR Oct 29, 2025
6b96273
KAFKA-19345: Use ShareFetchUtils mock for DelayedShareFetchTest tests…
brandboat Oct 29, 2025
23b809a
KAFKA-19301 Move and rewrite partition state classes to Java in org.a…
joshua2519 Oct 29, 2025
0072bd9
KAFKA-19820 remove the unnecessary copy from AbstractFetch#fetchableP…
TaiJuWu Oct 29, 2025
2daf5be
KAFKA-16024: SaslPlaintextConsumerTest#testCoordinatorFailover is fla…
brandboat Oct 29, 2025
22efb48
KAFKA-19791; Add Idle Thread Ratio Metric to MetadataLoader (#20724)
MahsaSeifikar Oct 29, 2025
c31f699
KAFKA-19796: Introduce computations for inFlightTerminalRecords (#20787)
chirag-wadhwa5 Oct 29, 2025
05c9322
KAFKA-19814: Protocol and API changes for KIP-1222 (#20732)
AndrewJSchofield Oct 30, 2025
5c49b48
MINOR: Correct javadoc and comment in AbstractFetch#fetchablePartitio…
majialoong Oct 30, 2025
9550867
MINOR: Fix removal warning in connect:runtime:test (#20793)
mimaison Oct 30, 2025
42604b4
KAFKA-19807: Add RPC-level integration tests for StreamsGroupHeartbea…
lucliu1108 Oct 30, 2025
059589e
KAFKA-19606; Implement request handler metrics defined in KIP-1207 (#…
0xffff-zhiyan Oct 30, 2025
53e1172
KAFKA-19807: Add RPC-level integration tests for StreamsGroupHeartbea…
lucliu1108 Oct 30, 2025
75768dd
MINOR: Prevent re-join flakiness in test_fencing_static_consumer by e…
apalan60 Oct 31, 2025
e846491
KAFKA-19755 Move KRaftClusterTest from core module to server module […
DL1231 Oct 31, 2025
346cf12
MINOR: Update testIdleTimeCallback in KafkaEventQueueTest (#20798)
MahsaSeifikar Oct 31, 2025
638a586
MINOR: Remove MemoryRecords.idempotentBuilder and replace its usage w…
Abyss-lord Oct 31, 2025
7a75817
MINOR: Checkstyle ImportControl cleanup (#20789)
majialoong Nov 1, 2025
0facc3c
KAFKA-19813 Incorrect jitter value in StreamsGroupHeartbeatRequestMan…
brandboat Nov 1, 2025
1e547de
MINOR: Update inconsistent description for kafka-streams-application-…
Yunyung Nov 1, 2025
d78b4ec
MINOR: Use explicit AcknowledgeType enums in SharePartitionTest (#20802)
JimmyWang6 Nov 2, 2025
806baad
MINOR: Fix typos in RPC files (#20800)
sjhajharia Nov 2, 2025
28ff2a4
KAFKA-19426 TopicBasedRemoteLogMetadataManager's initial should happe…
jiafu1115 Nov 2, 2025
54cf2eb
MINOR: Initialize fetchPartitionStatus as a Map type to reduce collec…
DL1231 Nov 2, 2025
8900a18
KAFKA-12999 Make RecordHeader reads thread-safe (KIP-1205) (#20751)
mingyen066 Nov 2, 2025
5d1c231
KAFKA-19855 Fix a typo in README.md file (#20809)
devtrace404 Nov 3, 2025
2da6a55
MINOR: Fix StreamsGroupHeartbeatRequest Test Typo (#20803)
lucliu1108 Nov 3, 2025
904b459
KAFKA-19683: More cleanup and rewrite [4/N] (#20777)
shashankhs11 Nov 3, 2025
52a38c8
MINOR: Fix the typo “milli seconds” to “milliseconds” (#20812)
jiafu1115 Nov 3, 2025
d0846bd
MINOR: Remove out-of-date comments from GC record schemas (#20814)
AndrewJSchofield Nov 3, 2025
cc869d9
MINOR: Fix help message for downgrade feature flag in kafka-features.…
mingyen066 Nov 3, 2025
c5ae7b4
KAFKA-18794: Add check to send one ShareFetchEvent per poll in ShareC…
ShivsundarR Nov 3, 2025
b900f2f
KAFKA-19797: Added deliveryCompleteCount to writeState, ShareUpdate a…
chirag-wadhwa5 Nov 3, 2025
72532b6
KAFKA-18376: High CPU load when AsyncKafkaConsumer uses a small max p…
kirktrue Nov 3, 2025
c293afc
KAFKA-19614 The records appended to the log are illegal because of an…
jim0987795064 Nov 4, 2025
750523f
MINOR: Make feature upgrade instructions more precise (#20816)
lucasbru Nov 4, 2025
5571821
KAFKA-19799: Added deliveryCompleteCount to ReadShareGroupStateSummar…
chirag-wadhwa5 Nov 4, 2025
cfe85c2
KAFKA-19802: Admin client changes for KIP-1226 (#20771)
AndrewJSchofield Nov 4, 2025
680b871
KAFKA-19773: Include push interval in ClientTelemetryReceiver context…
see-quick Nov 4, 2025
e658d54
KAFKA-19843: SharePartition RENEW ack impl. (#20815)
smjn Nov 4, 2025
96f83be
KAFKA-19861: Optimization of the Murmur2 hash computation (#20359)
oertl Nov 4, 2025
46feafe
MINOR: Disable RemoteLogManagerTest.testCopyQuota for green builds. (…
smjn Nov 4, 2025
55764f8
KAFKA-19859: Start offset moved incorrectly on receiving acknowledgem…
adixitconfluent Nov 4, 2025
33ffe06
MINOR: added information about KIP-1034, KIP-1153, KIP-1195, and KIP-…
Nikita-Shupletsov Nov 5, 2025
fd72d4e
MINOR: Document null parameter behavior in ListShareGroupOffsetsSpec#…
Yunyung Nov 5, 2025
83bfbfe
MINOR: Correct PartitionMetadataReadBuffer error message (#20827)
majialoong Nov 5, 2025
6b7f54f
MINOR: use removal supress warning in ClientMetricsTestUtils (#20830)
brandboat Nov 5, 2025
baec231
MINOR: Fix warnings in build (#20801)
sjhajharia Nov 5, 2025
c205e69
KAFKA-19020 [1/n]: Handle strict max fetch records in share fetch (#2…
JimmyWang6 Nov 5, 2025
ef4b04b
KAFKA-19844: ShareFetch related changes to support RENEW. (#20826)
smjn Nov 5, 2025
61e63f1
KAFKA-19822 Remove all unused static classes in Field (#20799)
DL1231 Nov 5, 2025
c888297
KAFKA-19779: Track assignment epochs in streams groups [3/N] (#20730)
lucasbru Nov 6, 2025
d5d9892
KAFKA-19779: Add per-partition epoch validation to streams groups [4…
lucasbru Nov 6, 2025
bd8ea36
KAFKA-19846: Remove uuid to string conversion and vice-versa for memb…
adixitconfluent Nov 6, 2025
1f23bb1
MINOR: Include exception objects when logging group coordinator error…
squah-confluent Nov 6, 2025
57456b3
KAFKA-19479: Add test to verify data-loss bug was fixed inside the pr…
shashankhs11 Nov 7, 2025
22db7b9
KAFKA-19683: More test replacements [5/N] (#20818)
shashankhs11 Nov 7, 2025
9b0c9db
KAFKA-19864: Handle TimeoutException from initializeIfNeeded() in Sta…
shashankhs11 Nov 7, 2025
3255a73
KAFKA-19831: removed the futureless remove task as it's no longer use…
Nikita-Shupletsov Nov 7, 2025
cc62985
MINOR: Propagate ShareFetch acknowledgement error messages from broke…
TaiJuWu Nov 7, 2025
738a7e0
MINOR: add docs for streams kip (#20834)
RaidenE1 Nov 7, 2025
2443b6f
MINOR: Fix KafkaApisTest sharePartitionManager and ShareSessionContex…
lucliu1108 Nov 8, 2025
907e56d
KAFKA-19868 Add client id to share consumers in ShareConsumerPerforma…
adixitconfluent Nov 9, 2025
68800a0
KAFKA-19301 Move partition state classes from storage to server modul…
joshua2519 Nov 9, 2025
fffb843
KAFKA-19578 Fix flaky test for RemoteLogManagerTest.testCopyQuota (#2…
jiafu1115 Nov 10, 2025
de7e632
MINOR: Fix incomplete Javadoc comments in storage module (#20778)
atheendre130505 Nov 10, 2025
19fea36
MINOR: improve quickstart (#20846)
mjsax Nov 10, 2025
d9d9fcb
KAFKA-19757: [1/N] Mark KIP-932 as generally available (#20856)
AndrewJSchofield Nov 10, 2025
188b86f
KAFKA-19793 Adding allow topic creation false for global and restore …
iit2009060 Nov 10, 2025
721cc0c
MINOR: Fix --fetch-size description in ConsumerPerformance (#20835)
mingyen066 Nov 11, 2025
1146f97
KAFKA-19800: Compute share partition lag in GroupCoordinatorService (…
chirag-wadhwa5 Nov 11, 2025
e02db7f
KAFKA-19493: Incorrect rate metric with larger window size (#20152)
DL1231 Nov 11, 2025
214bb07
KAFKA-19845: [1/N] Renew acks in share consumer (#20838)
AndrewJSchofield Nov 11, 2025
ff5b443
MINOR: Improve endpoint information epoch management in Streams group…
lucasbru Nov 12, 2025
b73b1ae
MINOR: Removed unused struct in StreamsGroupDescribeResponse.json (#2…
lucasbru Nov 12, 2025
da596f6
KAFKA-15283:[1/N] Client support for OffsetCommit with topic ID (#19577)
DL1231 Nov 12, 2025
58d439a
KAFKA-14768 Add latency optimization guidance to KafkaProducer.send()…
jiafu1115 Nov 12, 2025
06c9213
KAFKA-19682: Add logs for Kafka Streams task readiness (#20693)
lucliu1108 Nov 12, 2025
faad21f
KAFKA-19446: Add transaction version field [1/3] (#20857)
rreddy-22 Nov 12, 2025
f685d57
MINOR: update collaborators (#20869)
lianetm Nov 12, 2025
1fdb011
MINOR: Fix topic option description in kafka-topics.sh (#20865)
DL1231 Nov 13, 2025
b9f0742
MINOR: Add toString() to TaskAssignor implementations for better logg…
lucasbru Nov 13, 2025
4e551de
KAFKA-19039: The refresh_collaborators.py script messes .asf.yaml (#1…
decaf12 Nov 13, 2025
b3fb10b
MINOR: Fix typo in Streams DSL description (#20876)
ghalamif Nov 13, 2025
5537dbb
MINOR: Fix typos and grammatical errors in dsl-api.html (#20878)
ghalamif Nov 13, 2025
05fd35a
MINOR: Fix typo in timestamp explanation in dsl-api.html (#20879)
ghalamif Nov 13, 2025
7b09531
MINOR: Docs for kafka-share-groups.sh --reset-offsets (#20867)
AndrewJSchofield Nov 13, 2025
958cb31
MINOR: make description more clear for group.protocol (#20870)
joel-hamill Nov 13, 2025
39c2d6f
MINOR: update docker_scan.yaml with 4.1.1 (#20881)
lianetm Nov 14, 2025
7ee5a2a
KAFKA-19446: Add Transaction Version to request builder [2/3] (#20868)
rreddy-22 Nov 14, 2025
0ef1394
MINOR: Add plugin.path config non-empty check in connect-plugin-path.…
majialoong Nov 14, 2025
7199019
MINOR: Remove early access warning for streams rebalance protocol (#2…
mingyen066 Nov 14, 2025
d0ef66b
KAFKA-19829: Implement group-level initial rebalance delay (#20755)
RaidenE1 Nov 14, 2025
959818f
KAFKA-19683: More test replacements [6/N] (#20858)
shashankhs11 Nov 14, 2025
497072a
KAFKA-19869: Mark streams groups records and APIs stable (#20841)
lucasbru Nov 14, 2025
21f19e0
MINOR: Update 4.1 docs (#20743)
lianetm Nov 14, 2025
e32fb97
KAFKA-19825 [1/2]: Add coordinator effective batch linger time metric…
squah-confluent Nov 14, 2025
403f6c1
KAFKA-19840: Handle exceptions in acknowledgement callback (#20880)
AndrewJSchofield Nov 14, 2025
e990941
KAFKA-19825 [2/2]: Add coordinator batch flush rate metric (#20754)
squah-confluent Nov 14, 2025
d9462c2
KAFKA-19857: Fix CoordinatorExecutorImpl.cancelAll implementation (#2…
squah-confluent Nov 14, 2025
c635a76
KAFKA-19638: Set dummy ProcessorRecordContext for processor init (#20…
eduwercamacaro Nov 14, 2025
b03c996
MINOR: Add client response auth and version exp handling. (#20884)
smjn Nov 14, 2025
b58aae2
KAFKA-19826: Implement coordinator adaptive batch linger time (#20780)
squah-confluent Nov 14, 2025
69e1c91
KAFKA-19876 Replace the base image since openjdk image is deprecated …
m1a2st Nov 15, 2025
02bd342
KAFKA-19449: Don't consider partitions unreleased when pending revoca…
squah-confluent Nov 15, 2025
0f4dbf7
KAFKA-19720: Regex subscription should be empty for classic members j…
dongnuo123 Nov 15, 2025
3ef689b
MINOR: Correct the typo 'paramter' to 'parameter' (#20888)
jiafu1115 Nov 15, 2025
8461ae3
KAFKA-19800-2: Created an implementation class NetworkPartitionMetada…
chirag-wadhwa5 Nov 17, 2025
ab6755c
KAFKA-19815: Implement acquisitionLockTimeoutMs (#20895)
AndrewJSchofield Nov 17, 2025
169e211
KAFKA-19892: Add acq lock timeout ms field to share ack response. (#2…
smjn Nov 17, 2025
8bdafb4
KAFKA-7699: Anchored punctuation (#19937)
hermanjakobsen Nov 17, 2025
9529003
MINOR Use new Develocity secret for flaky test report (#20344)
mumrah Nov 17, 2025
33c5e84
KAFKA-7699: KIP-1146 notable change docs for 4.2.0 (#20903)
hermanjakobsen Nov 17, 2025
81d86e5
KAFKA-19845: 2/N Additional share consumers tests. (#20900)
smjn Nov 18, 2025
3f8ca85
MINOR: Correct missing space in RecordState exception message (#20902)
majialoong Nov 18, 2025
5cc4c87
KAFKA-19394: Failure in ConsumerNetworkThread.initializeResources() c…
kirktrue Nov 18, 2025
0491e11
KAFKA-19892: Client use of ShareAcknowledge acquisition lock timeout …
AndrewJSchofield Nov 18, 2025
108ad6e
KAFKA-19767 - Send Share-Fetch one-node at a time for record_limit mo…
ShivsundarR Nov 18, 2025
289a010
MINOR: add 4.1.1 to system tests (#20887)
lianetm Nov 18, 2025
5373f2d
KAFKA-15283:[2/2] Client support for OffsetFetch with topic ID (#19885)
DL1231 Nov 18, 2025
aaadb2b
MINOR: Document Java 25 as a supported Java version (#20917)
majialoong Nov 19, 2025
a18384b
KAFKA-19756 Add documentation for Gradle version upgrade process (#20…
joshua2519 Nov 19, 2025
26e45f6
KAFKA-19894 Reintroduce SaslPlainSslEndToEndAuthorizationTest (#20915)
gaurav-narula Nov 19, 2025
31330e2
KAFKA-19777 : Generator | Fix order of arguments to assertEquals in u…
samarth-ksolves Nov 19, 2025
679854c
KAFKA-19896: Use MockTime::sleep in ShareConsumeRequestManagerTest. (…
ShivsundarR Nov 19, 2025
4a8ad8e
KAFKA-19781: Fix to not update positions for partitions being revoked…
lianetm Nov 19, 2025
c1ded05
KAFKA-19446: Propagate transaction version info to producer epoch che…
rreddy-22 Nov 19, 2025
bb95e3a
KAFKA-19882: Cleaning client level metric tags (#20906)
gensericghiro Nov 19, 2025
48f6d76
KAFKA-19898: Close ConsumerNetworkThread on failed start (#20930)
AndrewJSchofield Nov 19, 2025
94d3355
MINOR: Fix zombie process issue in ducker containers by using `--init…
m1a2st Nov 20, 2025
fb56f8a
KAFKA-19364: Share consumer javadoc enhancements (#20918)
AndrewJSchofield Nov 20, 2025
b443130
KAFKA-19757: Interface stability and deprecation (#20916)
AndrewJSchofield Nov 20, 2025
64cb839
KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShar…
ShivsundarR Nov 20, 2025
56c46f8
KAFKA-19364: KIP-932 documentation updates (#20925)
AndrewJSchofield Nov 20, 2025
19b655f
KAFKA-19715 Consider bumping 3rd party Github Actions (#20929)
jim0987795064 Nov 20, 2025
9599143
KAFKA-19186; Mark OffsetCommit and OffsetFetch APIs as stable (#20923)
dajac Nov 20, 2025
b2a9112
KAFKA-19683: Some more test replacements [7/N] (#20889)
shashankhs11 Nov 20, 2025
d51f195
MINOR: Make acq lock timeout ignorable in share ack response. (#20934)
smjn Nov 20, 2025
3fd4892
KAFKA-19860: Integration tests for KIP-1226 (#20909)
chirag-wadhwa5 Nov 20, 2025
dc9ae8b
MINOR: Gradle version update: 9.1.0 -->> 9.2.1 (#20932)
dejan2609 Nov 20, 2025
8036182
MINOR: Fixing doc typo (#20941)
gensericghiro Nov 20, 2025
e8d5cc1
MINOR: Tidy javadoc packages (#20936)
AndrewJSchofield Nov 20, 2025
5ab7f0b
KAFKA-19734: Updating the docs for KIP-1221 (#20804)
gensericghiro Nov 20, 2025
24b6fc0
MINOR: Cleanup in ShareConsumerTest (#20940)
ShivsundarR Nov 20, 2025
bcd3191
KAFKA-17541:[2/2] Improve handling of delivery count (#20837)
DL1231 Nov 21, 2025
df436cc
MINOR: improve logging for Kafka Streams stateful task management (#2…
mjsax Nov 21, 2025
8b119e5
MINOR: Fix library name jacksonDatabindYaml -> jacksonDataformatYaml …
Philippus Nov 21, 2025
60725ea
merge: apache/kafka trunk 8b119e5105 (before 4.3.0-SNAPSHOT)
jeqo Feb 5, 2026
0ea657a
fix(sync): fix compilation errors after upstream merge
jeqo Feb 5, 2026
161ca84
docs(sync): document compilation fixes in SESSION-2025-11-21.md
jeqo Feb 5, 2026
08b1367
docs(sync): update SESSION-2025-11-21.md with test results
jeqo Feb 5, 2026
42e9b13
fix(test): configure NoOpRemoteLogMetadataManager in InklessConfigsTest
jeqo Feb 5, 2026
dde0dd1
docs(sync): update SESSION with InklessConfigsTest fix
jeqo Feb 5, 2026
7723727
docs(sync): finalize SESSION-2025-11-21.md - sync complete
jeqo Feb 5, 2026
d316a3c
fix(sync): restore FlattenedIteratorTest for retained FlattenedIterator
jeqo Feb 5, 2026
92a1194
refactor(sync): use util.LinkedHashMap to match upstream pattern
jeqo Feb 5, 2026
df2ec2d
refactor(sync): align core files with upstream-sync-before-4.3
jeqo Feb 5, 2026
1796342
docs(sync): add follow-up item for Java consumer tests diskless support
jeqo Feb 5, 2026
f7d4780
fix(sync): exclude .sync directory from RAT license check
jeqo Feb 5, 2026
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
  •  
  •  
  •  
8 changes: 4 additions & 4 deletions .asf.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -30,14 +30,14 @@ notifications:
github:
collaborators:
- brandboat
- FrankYang0529
- gongxuanzhang
- chirag-wadhwa5
- DL1231
- m1a2st
- mingyen066
- ShivsundarR
- Rancho-7
- sjhajharia
- smjn
- TaiJuWu
- xijiu
- Yunyung
enabled_merge_buttons:
squash: true
Expand Down
5 changes: 5 additions & 0 deletions .github/actions/run-gradle/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -83,6 +83,9 @@ runs:
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 &
Expand All @@ -97,6 +100,8 @@ runs:
-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
Expand Down
4 changes: 2 additions & 2 deletions .github/actions/setup-gradle/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -37,12 +37,12 @@ runs:
using: "composite"
steps:
- name: Setup Java
uses: actions/setup-java@v4
uses: actions/setup-java@v5
with:
distribution: temurin
java-version: ${{ inputs.java-version }}
- name: Setup Gradle
uses: gradle/actions/setup-gradle@94baf225fe0a508e581a564467443d0e2379123b # v4.3.0
uses: gradle/actions/setup-gradle@4d9f0ba0025fe599b4ebab900eb7f3a1d93ef4c2 # v5.0.0
env:
GRADLE_BUILD_ACTION_CACHE_DEBUG_ENABLED: true
with:
Expand Down
2 changes: 1 addition & 1 deletion .github/actions/setup-python/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ runs:
using: "composite"
steps:
- name: Setup Python
uses: actions/setup-python@v5
uses: actions/setup-python@v6
with:
python-version: 3.12
- name: Pip install
Expand Down
6 changes: 6 additions & 0 deletions .github/configs/labeler.yml
Original file line number Diff line number Diff line change
Expand Up @@ -92,6 +92,12 @@ transactions:
- any-glob-to-any-file:
- 'transaction-coordinator/**'

group-coordinator:
- changed-files:
- any-glob-to-any-file:
- 'group-coordinator/**'
- 'coordinator-common/**'

kip-932:
- changed-files:
- any-glob-to-any-file:
Expand Down
4 changes: 3 additions & 1 deletion .github/scripts/requirements.txt
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,8 @@
# 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.

# Note: Ensure the 'requests' version here matches the version in tests/setup.py
PyYAML~=6.0
pytz==2024.2
requests==2.32.3
requests==2.32.4
33 changes: 15 additions & 18 deletions .github/workflows/build.yml
Original file line number Diff line number Diff line change
Expand Up @@ -66,12 +66,12 @@ jobs:
name: Load Test Catalog
steps:
- name: Checkout main
uses: actions/checkout@v4
uses: actions/checkout@v5
with:
persist-credentials: false

- name: Checkout test-catalog
uses: actions/checkout@v4
uses: actions/checkout@v5
with:
ref: 'test-catalog'
persist-credentials: false
Expand Down Expand Up @@ -118,7 +118,7 @@ jobs:
env:
GITHUB_CONTEXT: ${{ toJson(github) }}
- name: Checkout code
uses: actions/checkout@v4
uses: actions/checkout@v5
with:
persist-credentials: false
ref: ${{ github.sha }} # this is the default, just being explicit.
Expand All @@ -127,10 +127,7 @@ jobs:
- name: Setup Gradle
uses: ./.github/actions/setup-gradle
with:
# Inkless: Downgrading to 17 as jooq classes are generated (or cached) with this-escape
# and can't find how to overcome this issue. Leaving it at JDK17 for the checks,
# as both JDKs 17 and 23 are tested in the next phase
java-version: 17
java-version: 25
gradle-cache-read-only: ${{ !inputs.is-trunk }}
gradle-cache-write-only: ${{ inputs.is-trunk }}
develocity-access-key: ${{ secrets.DEVELOCITY_ACCESS_KEY }}
Expand Down Expand Up @@ -185,7 +182,7 @@ jobs:
fail-fast: false
matrix:
# If we change these, make sure to adjust ci-complete.yml
java: [ 23, 17 ]
java: [ 25, 17 ]
run-flaky: [ true, false ]
run-new: [ true, false ]
exclude:
Expand All @@ -196,7 +193,7 @@ jobs:
name: JUnit tests Java ${{ matrix.java }}${{ matrix.run-flaky == true && ' (flaky)' || '' }}${{ matrix.run-new == true && ' (new)' || '' }}
steps:
- name: Checkout code
uses: actions/checkout@v4
uses: actions/checkout@v5
with:
persist-credentials: false
ref: ${{ needs.configure.outputs.sha }}
Expand All @@ -214,7 +211,7 @@ jobs:
# the overall workflow, so we'll continue here without a test catalog.
- name: Load Test Catalog
id: load-test-catalog
uses: actions/download-artifact@v4
uses: actions/download-artifact@v5
continue-on-error: true
with:
name: combined-test-catalog
Expand Down Expand Up @@ -280,7 +277,7 @@ jobs:
python .github/scripts/junit.py \
--path build/junit-xml >> $GITHUB_STEP_SUMMARY

# This job downloads all the JUnit XML files and thread dumps from the JDK 23 test runs.
# This job downloads all the JUnit XML files and thread dumps from the JDK 25 test runs.
# If any test job fails, we will not run this job. Also, if any thread dump artifacts
# are present, this means there was a timeout in the tests and so we will not proceed
# with catalog creation.
Expand All @@ -292,13 +289,13 @@ jobs:
uploaded-test-catalog: ${{ steps.archive-test-catalog.outcome == 'success' }}
steps:
- name: Checkout code
uses: actions/checkout@v4
uses: actions/checkout@v5
with:
persist-credentials: false
- name: Download Thread Dumps
uses: actions/download-artifact@v4
uses: actions/download-artifact@v5
with:
pattern: junit-thread-dumps-23-*
pattern: junit-thread-dumps-25-*
path: thread-dumps
merge-multiple: true
- name: Check For Thread Dump
Expand All @@ -310,9 +307,9 @@ jobs:
exit 1;
fi
- name: Download JUnit XMLs
uses: actions/download-artifact@v4
uses: actions/download-artifact@v5
with:
pattern: junit-xml-23-* # Only look at JDK 23 tests for the test catalog
pattern: junit-xml-25-* # Only look at JDK 25 tests for the test catalog
path: junit-xml
merge-multiple: true
- name: Collate Test Catalog
Expand Down Expand Up @@ -344,15 +341,15 @@ jobs:
contents: write
steps:
- name: Checkout Test Catalog
uses: actions/checkout@v4
uses: actions/checkout@v5
with:
persist-credentials: true # Needed to commit and push later
ref: test-catalog
- name: Reset Catalog
run: |
rm -rf test-catalog
- name: Download Test Catalog
uses: actions/download-artifact@v4
uses: actions/download-artifact@v5
with:
name: test-catalog
path: test-catalog
Expand Down
10 changes: 5 additions & 5 deletions .github/workflows/ci-complete.yml
Original file line number Diff line number Diff line change
Expand Up @@ -43,8 +43,8 @@ jobs:
strategy:
fail-fast: false
matrix:
# Make sure these match build.yml
java: [ 23, 17 ]
# Make sure these match build.yml and also keep in mind that GitHub Actions build will always use this file from the trunk branch.
java: [ 25, 17 ]
run-flaky: [ true, false ]
run-new: [ true, false ]
exclude:
Expand All @@ -61,7 +61,7 @@ jobs:
env:
GITHUB_CONTEXT: ${{ toJson(github) }}
- name: Checkout code
uses: actions/checkout@v4
uses: actions/checkout@v5
with:
persist-credentials:
false
Expand All @@ -72,7 +72,7 @@ jobs:
develocity-access-key: ${{ secrets.DEVELOCITY_ACCESS_KEY }}
- name: Download build scan archive
id: download-build-scan
uses: actions/download-artifact@v4
uses: actions/download-artifact@v5
continue-on-error: true # Don't want this step to fail the overall workflow
with:
github-token: ${{ github.token }}
Expand All @@ -89,7 +89,7 @@ jobs:
url: '${{ github.event.workflow_run.html_url }}'
description: 'Could not find build scan'
context: Gradle Build Scan / ${{ env.status-context }}
state: 'error'
state: 'success' # Always mark as successful as a temporary fix; non-trunk branches will miss build scan. Real fix in KAFKA-19768
- name: Publish Scan
id: publish-build-scan
if: ${{ steps.download-build-scan.outcome == 'success' }}
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/deflake.yml
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ jobs:
name: Deflake JUnit tests
steps:
- name: Checkout code
uses: actions/checkout@v4
uses: actions/checkout@v5
with:
persist-credentials: false

Expand Down
6 changes: 3 additions & 3 deletions .github/workflows/docker_build_and_test.yml
Original file line number Diff line number Diff line change
Expand Up @@ -32,9 +32,9 @@ jobs:
build:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v4
- uses: actions/checkout@v5
- name: Set up Python 3.10
uses: actions/setup-python@v5
uses: actions/setup-python@v6
with:
python-version: "3.10"
- name: Setup Docker Compose
Expand All @@ -54,7 +54,7 @@ jobs:
run: |
python docker_build_test.py kafka/test -tag=test -type=$IMAGE_TYPE -u=$KAFKA_URL
- name: Run CVE scan
uses: aquasecurity/trivy-action@6e7b7d1fd3e4fef0c5fa8cce1229c54b2c9bd0d8 # v0.24.0
uses: aquasecurity/trivy-action@b6643a29fecd7f34b3597bc6acb0a98b03d33ff8 # v0.33.1
with:
image-ref: 'kafka/test:test'
format: 'table'
Expand Down
6 changes: 3 additions & 3 deletions .github/workflows/docker_official_image_build_and_test.yml
Original file line number Diff line number Diff line change
Expand Up @@ -31,9 +31,9 @@ jobs:
build:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v4
- uses: actions/checkout@v5
- name: Set up Python 3.10
uses: actions/setup-python@v5
uses: actions/setup-python@v6
with:
python-version: "3.10"
- name: Setup Docker Compose
Expand All @@ -53,7 +53,7 @@ jobs:
run: |
python docker_official_image_build_test.py kafka/test -tag=test -type=$IMAGE_TYPE -v=$KAFKA_VERSION
- name: Run CVE scan
uses: aquasecurity/trivy-action@6e7b7d1fd3e4fef0c5fa8cce1229c54b2c9bd0d8 # v0.24.0
uses: aquasecurity/trivy-action@b6643a29fecd7f34b3597bc6acb0a98b03d33ff8 # v0.33.1
with:
image-ref: 'kafka/test:test'
format: 'table'
Expand Down
6 changes: 3 additions & 3 deletions .github/workflows/docker_promote.yml
Original file line number Diff line number Diff line change
Expand Up @@ -31,11 +31,11 @@ jobs:
runs-on: ubuntu-latest
steps:
- name: Set up QEMU
uses: docker/setup-qemu-action@49b3bc8e6bdd4a60e6116a5414239cba5943d3cf # v3.2.0
uses: docker/setup-qemu-action@c7c53464625b32c7a7e944ae62b3e17d2b600130 # v3.7.0
- name: Set up Docker Buildx
uses: docker/setup-buildx-action@988b5a0280414f521da01fcc63a27aeeb4b104db # v3.6.1
uses: docker/setup-buildx-action@e468171a9de216ec08956ac3ada2f0791b6bd435 # v3.11.1
- name: Login to Docker Hub
uses: docker/login-action@9780b0c442fbb1117ed29e0efdff1e18412f7567 # v3.3.0
uses: docker/login-action@5e57cd118135c172c3672efd75eb46360885c0ef # v3.6.0
with:
username: ${{ secrets.DOCKERHUB_USER }}
password: ${{ secrets.DOCKERHUB_TOKEN }}
Expand Down
10 changes: 5 additions & 5 deletions .github/workflows/docker_rc_release.yml
Original file line number Diff line number Diff line change
Expand Up @@ -37,21 +37,21 @@ jobs:
runs-on: ubuntu-latest
steps:
- name: Checkout
uses: actions/checkout@v4
uses: actions/checkout@v5
- name: Set up Python 3.10
uses: actions/setup-python@v5
uses: actions/setup-python@v6
with:
python-version: "3.10"
- name: Install dependencies
run: |
python -m pip install --upgrade pip
pip install -r docker/requirements.txt
- name: Set up QEMU
uses: docker/setup-qemu-action@49b3bc8e6bdd4a60e6116a5414239cba5943d3cf # v3.2.0
uses: docker/setup-qemu-action@c7c53464625b32c7a7e944ae62b3e17d2b600130 # v3.7.0
- name: Set up Docker Buildx
uses: docker/setup-buildx-action@988b5a0280414f521da01fcc63a27aeeb4b104db # v3.6.1
uses: docker/setup-buildx-action@e468171a9de216ec08956ac3ada2f0791b6bd435 # v3.11.1
- name: Login to Docker Hub
uses: docker/login-action@9780b0c442fbb1117ed29e0efdff1e18412f7567 # v3.3.0
uses: docker/login-action@5e57cd118135c172c3672efd75eb46360885c0ef # v3.6.0
with:
username: ${{ secrets.DOCKERHUB_USER }}
password: ${{ secrets.DOCKERHUB_TOKEN }}
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/docker_scan.yml
Original file line number Diff line number Diff line change
Expand Up @@ -26,10 +26,10 @@ jobs:
strategy:
matrix:
# This is an array of supported tags. Make sure this array only contains the supported tags
supported_image_tag: ['latest', '3.7.2', '3.8.1', '3.9.1', '4.0.0']
supported_image_tag: ['latest', '3.9.1', '4.0.1', '4.1.1']
steps:
- name: Run CVE scan
uses: aquasecurity/trivy-action@6e7b7d1fd3e4fef0c5fa8cce1229c54b2c9bd0d8 # v0.24.0
uses: aquasecurity/trivy-action@b6643a29fecd7f34b3597bc6acb0a98b03d33ff8 # v0.33.1
if: always()
with:
image-ref: apache/kafka:${{ matrix.supported_image_tag }}
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/generate-reports.yml
Original file line number Diff line number Diff line change
Expand Up @@ -33,12 +33,12 @@ jobs:
env:
GITHUB_CONTEXT: ${{ toJson(github) }}
- name: Checkout code
uses: actions/checkout@v4
uses: actions/checkout@v5
- name: Setup Python
uses: ./.github/actions/setup-python
- name: Run Report
if : ${{ ! github.event.repository.fork }}
env:
DEVELOCITY_ACCESS_TOKEN: ${{ secrets.DV_API_ACCESS }}
DEVELOCITY_ACCESS_TOKEN: ${{ secrets.KAFKA_DEVELOCITY_ACCESS_KEY }}
run: |
python ./.github/scripts/develocity_reports.py >> $GITHUB_STEP_SUMMARY
2 changes: 1 addition & 1 deletion .github/workflows/pr-labeled.yml
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ jobs:
env:
GITHUB_CONTEXT: ${{ toJson(github) }}
- name: Checkout code
uses: actions/checkout@v4
uses: actions/checkout@v5
with:
persist-credentials:
false
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/pr-labels-cron.yml
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ jobs:
env:
GITHUB_CONTEXT: ${{ toJson(github) }}
- name: Remove label
uses: actions/github-script@v7
uses: actions/github-script@v8
continue-on-error: true
with:
github-token: ${{ secrets.GITHUB_TOKEN }}
Expand Down Expand Up @@ -77,7 +77,7 @@ jobs:
issues: write
pull-requests: write
steps:
- uses: actions/stale@v9
- uses: actions/stale@v10
with:
debug-only: ${{ inputs.dryRun || false }}
operations-per-run: ${{ inputs.operationsPerRun || 500 }}
Expand Down
Loading