Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7108 commits
Select commit Hold shift + click to select a range
5a2dcf8
KAFKA-20173: Ensure Metered session-stores pass headers correctly (#2…
mjsax Apr 7, 2026
b954b35
KAFKA-20332: Fix to ensure app thread not collecting records for part…
lianetm Apr 8, 2026
40e9fcd
KAFKA-20119 Clarify that `Consumer#unsubscribe` does not trigger auto…
TaiJuWu Apr 8, 2026
112686c
MINOR: fix typo in KafkaAdminClient to align the meaning (#21988)
cychiu8 Apr 8, 2026
06bedcf
MINOR: Fix log statement formatting in KafkaAdminClient (#21990)
JiayaoS Apr 8, 2026
579a4e0
KAFKA-20219: Headers store with caching enabled should reject queries…
zheguang Apr 8, 2026
f4afec0
MINOR: Fix double negative typos in Javadoc and exception messages (#…
xxxxxxjun Apr 8, 2026
53629a2
KAFKA-20307: expose header-stores natively in IQv1 (#21992)
mjsax Apr 8, 2026
7e1c9db
KAFKA-20332 [2]: Handle wakeup on poll reconciliation check (#21997)
lianetm Apr 8, 2026
94fc9ad
KAFKA-20194: Add sesssion-header-store support to TDD (#21956)
mjsax Apr 8, 2026
06f6996
KAFKA-20415: Add share.version=2 for gated DLQ support. (#21994)
smjn Apr 8, 2026
433f06a
KAFKA-20329: Test `headers` dsl.store.format further (1/N) (#21806)
aliehsaeedii Apr 8, 2026
db3ece1
KAFKA-20264: fix overwrite in recursive parent-node matching (#21540)
appchemist Apr 8, 2026
1738c30
KAFKA-19863: Add documentation on how to implement a custom exception…
Rajarshi-Misra Apr 9, 2026
930f4ea
KAFKA-20194: Ensure backward compatibility for Windowed Store (#22004)
mjsax Apr 9, 2026
29254d6
KAFKA-20425: Optimize purgatory triggers when no data is available fo…
apoorvmittal10 Apr 9, 2026
6f4b47d
KAFKA-20089 clients - update javadocs -- while topic being created i…
muralibasani Apr 9, 2026
b908dd7
MINOR: Bump Jackson to 2.21.2 (#22008)
mimaison Apr 9, 2026
e4cd243
KAFKA-20337 Make all GroupConfig fields Optional and clean up validat…
dajac Apr 9, 2026
123ee9e
KAFKA-20393: Fix stickyNode using stale IP when broker address change…
kwondh5217 Apr 9, 2026
7aaf4de
KAFKA-20182 Upgrade gradle to 9.4.1 and spotless to 8.3.0 (#22012)
mingyen066 Apr 10, 2026
be6feb2
KAFKA-20354: Add missing Control Batch types in documentation (#21866)
fvaleri Apr 10, 2026
a0446e3
KAFKA-20363 Fix flaky testIdleTimeCallback in KafkaEventQueueTest (#2…
muralibasani Apr 10, 2026
c0e77d1
KAFKA-19914: Move AlterPartitionManager to server module (#21432)
joshua2519 Apr 10, 2026
30edb58
KAFKA-20323: Refactor deleteRecords stub to use partition-based match…
ChoMinGi Apr 10, 2026
ec17e5a
KAFKA-20378 Make container memory limit configurable (#21924)
see-quick Apr 10, 2026
d5d9868
KAFKA-20431: ConsumerGroupDescribe API does not return partitions bei…
dajac Apr 10, 2026
917caae
KAFKA-20417: Add KIP-1035 self-managed offset recovery integration te…
bbejeck Apr 10, 2026
6c0778a
KAFKA-20245: DLQ share group client REJECT ack records. [2/N] (#21793)
smjn Apr 10, 2026
2fd5946
MINOR: fix the Custom Exception Handler Implementation example. (#22022)
Nikita-Shupletsov Apr 11, 2026
1980f38
MINOR: Fix tool package in kafka-dump-log.bat (#22014)
mimaison Apr 11, 2026
a332a84
MINOR: Various code cleanups in server (#22021)
mimaison Apr 11, 2026
4b9eddc
KAFKA-20428: Fix unsubscribe failure with assignment updates (#22011)
lianetm Apr 11, 2026
eb6ce0e
MINOR: Change trivy action (#22024)
FrankYang0529 Apr 12, 2026
acd37fc
MINOR: Fix arguments in trivy scan (#22032)
FrankYang0529 Apr 12, 2026
e30f771
MINOR: Code cleanup in server module (#22026)
nileshkumar3 Apr 13, 2026
0d9fe51
KAFKA-20434: Consumer group does not recompute assignment when static…
dajac Apr 13, 2026
4acdac6
MINOR: Flaky test fixes (#21986)
AndrewJSchofield Apr 14, 2026
2327e51
KAFKA-20182 Remove removeUnusedImports and upgrade spotless to 8.4.0 …
mingyen066 Apr 14, 2026
40de3a6
MINOR: Bump pytest from 8.3.3 to 9.0.3 in /tests (#22042)
dependabot[bot] Apr 14, 2026
37b1a07
MINOR: Move KafkaMetricsGroupTest from Scala to Java (#22028)
m1a2st Apr 14, 2026
f8aa614
MINOR: Clarify components not considered for security issues (#22048)
mimaison Apr 14, 2026
6278e10
KAFKA-20252: Migrate clearYammerMetrics to TestUtils (#21679)
dubeyKartikay Apr 14, 2026
6c651fb
KAFKA-20329: Test headers dsl.store.format further (3/N) (#21820)
aliehsaeedii Apr 14, 2026
e2b5eb6
KAFKA-20329: Test headers dsl.store.format further (4/N) (#21827)
aliehsaeedii Apr 14, 2026
23bce3d
KAFKA-20446 KAFKA-20447: Fix CVE-2026-28390 and CVE-2026-22184 (#22053)
FrankYang0529 Apr 14, 2026
f9d502b
MINOR: Clarify group.consumer.assignors doc about default assignor ch…
dajac Apr 14, 2026
402cb65
Revert "KAFKA-13499: Avoid restoring outdated records (#21901)"
mjsax Apr 14, 2026
571cf30
MINOR: fix incorrect JavaDocs for headers-stores (#22043)
mjsax Apr 14, 2026
676712f
MINOR: Delegate version updates to Gradle in release script (#22031)
FrankYang0529 Apr 14, 2026
c4823da
KAFKA-20165 [2]: Integration tests to validate different OffsetFetch …
lianetm Apr 14, 2026
972f32d
KAFKA-19768 Update ci-complete to support branch 4.0 buildscan upload…
mingyen066 Apr 14, 2026
b4c9775
KAFKA-20297 move KafkaThread, ThreadUtils, ExponentialBackoff and Exp…
cychiu8 Apr 14, 2026
a39e714
KAFKA-20449: Downgrade "not updating high watermark" log from WARN to…
tkornai Apr 14, 2026
7f9f34a
KAFKA-19649: Document ListOffsets API v11 and follower fetch from tie…
abhijeetk88 Apr 14, 2026
45c4bdc
MINOR: Clarify docs for consumer leave options & rebalances (#22058)
lianetm Apr 14, 2026
5268721
KAFKA-20442: Update consumer group assignment epoch when last member …
dajac Apr 15, 2026
56be355
KAFKA-20442: Update share group assignment epoch when last member lea…
dajac Apr 15, 2026
e08a150
KAFKA-20442: Update streams group assignment epoch when last member l…
dajac Apr 15, 2026
2299a06
KAFKA-20297: Move AbstractIterator, CircularIterator, CloseableIterat…
m1a2st Apr 15, 2026
3852c50
MINOR: add comma before "and" in README (#22064)
cychiu8 Apr 15, 2026
07a6da3
MINOR: Split up ShareConsumerTest (#22017)
AndrewJSchofield Apr 15, 2026
f95a1f9
MINOR: increase test visibility to public in client integration tests…
Nikita-Shupletsov Apr 15, 2026
2791424
MINOR: Use maybeSetDslStoreFormatHeaders helper in more streams test …
m1a2st Apr 16, 2026
e7a5688
KAFKA-20297 move Crc32C Checksums and Sanitizer from utils to utils.i…
cychiu8 Apr 16, 2026
78fd214
MINOR: formatting fix on UpdateRaftVoterRequest class declaration (#2…
ppatierno Apr 16, 2026
4d0a85f
KAFKA-20417: Add KIP-1035 self-managed offset lifecycle integration t…
bbejeck Apr 17, 2026
963bc6a
KAFKA-20373: Bump maven artifact to 3.9.15 (#21911)
averemee-si Apr 17, 2026
0749b32
MINOR: Fix ListValueStore's restoration in headers mode (#22068)
aliehsaeedii Apr 17, 2026
46773ce
KAFKA-14588 Move ConfigCommand to tools module (#22013)
mimaison Apr 18, 2026
a09f7ed
MINOR: Bump setup-qemu-action, setup-buildx-action, and login-action …
FrankYang0529 Apr 18, 2026
4ae78a3
KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStre…
m1a2st Apr 18, 2026
8ae35c0
MINOR: add DCL on get or create meter for performance improvement (#2…
YutaLin Apr 18, 2026
3b80855
MINOR: version updates for build and test dependencies (#21651)
dejan2609 Apr 20, 2026
f1f0d97
MINOR: remove un-necessary integration tags (#22095)
see-quick Apr 20, 2026
282eef9
MINOR: Add DCL to improve performance (#22098)
YutaLin Apr 20, 2026
75052bb
KAFKA-20422: Add DSL integration tests for header stores with explici…
aliehsaeedii Apr 21, 2026
b6d2503
KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1…
sjhajharia Apr 21, 2026
dc5f816
KAFKA-9914: Fix replication cycle detection (#22079)
tvainika Apr 21, 2026
4766b29
MINOR: Fix typos in UnifiedLog and LocalLog exception messages (#22107)
JiayaoS Apr 21, 2026
0a367aa
KAFKA-20297 Move OperatingSystem, Java, Exit... into internal (#22093)
m1a2st Apr 21, 2026
30cea6f
KAFKA-20456: Use lighter options for RocksDB offsets column family (#…
bbejeck Apr 21, 2026
63cc2f3
KAFKA-18149: Docs improvement for dynamic kraft quorum (#18350)
FrankYang0529 Apr 22, 2026
a3f1732
KAFKA-19193 Support rack-aware partitioning for Kafka producer (#19850)
ivanyu Apr 22, 2026
7b5d4ca
KAFKA-20362 Fall back to GitHub handle when reviewer email is unavail…
mingyen066 Apr 22, 2026
28402a3
MINOR: Move CreateTopicsRequestTest to clients-integration-tests and …
majialoong Apr 22, 2026
3e32d9a
MINOR: add missing javadoc to Metadata.java (#22106)
ivamly Apr 22, 2026
0d95e46
MINOR: Remove unnecessary min.assignment.interval.ms config from test…
squah-confluent Apr 23, 2026
e1cfea3
KAFKA-20505: Moving future completion out of locks for Share Partitio…
apoorvmittal10 Apr 23, 2026
c946802
KAFKA-20506 kafka-configs.sh can't delete the config from a offline b…
m1a2st Apr 23, 2026
1938d32
MINOR: Removed `setMetadataLogDirectory` unused method (#22128)
ppatierno Apr 23, 2026
150f09f
KAFKA-20519 Fix broken links in configuration option docs (#22127)
scholzj Apr 23, 2026
0dad6a7
KAFKA-20512 : Fix flakiness - same output topic is being used for all…
muralibasani Apr 24, 2026
76dcd5f
MINOR: Reduce duplicate parameter combinations in heavy Streams integ…
aliehsaeedii Apr 27, 2026
d0e0ec4
KAFKA-20312: Handle null leader during OffsetFetcher regroup safely (…
nileshkumar3 Apr 27, 2026
3c9b210
KAFKA-20456: Avoid persisting closed state if store is not open yet (…
eduwercamacaro Apr 27, 2026
eef6cab
KAFKA-20450 Allowlist based SafeObjectInputStream (#22056)
subbudvk Apr 28, 2026
ddec811
KAFKA-19937: Introduced Shared ReaperThread for Persister / NetworkPa…
rionmonster Apr 28, 2026
8afeecc
MINOR: Add streams group tests to GroupCoordinatorIntegrationTest (#2…
lucasbru Apr 28, 2026
44bafc6
KAFKA-20426 Using both group.id and assign() causes a busy loop in As…
brandboat Apr 28, 2026
90a4c93
MINOR: Fix testRackAwareAssignment flake (#22154)
squah-confluent Apr 28, 2026
c75e10d
KAFKA-20424 : clients: Update KafkaConsumerTest comments,tests with r…
muralibasani Apr 28, 2026
2dfdb70
MINOR: Fix typo in testConsumerGroupHeartbeatRebalance (#22119)
squah-confluent Apr 28, 2026
20c2450
MINOR: Reshape TxnOffsetCommitResponse.Builder (#22146)
dajac Apr 28, 2026
7340eef
MINOR: Reshape TxnOffsetCommitRequest.Builder (#22147)
dajac Apr 28, 2026
82d0c12
MINOR: Add topicId parameter to OffsetAndMetadata.fromRequest for Txn…
dajac Apr 28, 2026
d02723a
MINOR: Add shutdown broker and bootstrap controller for ConfigCommand…
m1a2st Apr 28, 2026
f47b9a4
KAFKA-20362 Resolve reviewer email via GitHub commit search API (#22135)
mingyen066 Apr 28, 2026
ebd7cd3
MINOR: Document transaction.timeout.ms behavior under EOS in Streams …
lucasbru Apr 28, 2026
a310bcb
MINOR: system-tests: fix KafkaServer#leader (#22168)
gaurav-narula Apr 28, 2026
e6653a9
MINOR: Fix Javadoc for ConfigCommand.java (#22101)
Atharv3221 Apr 28, 2026
07e0cae
KAFKA-18652: Add `num.warmup.replicas` config (#21801)
mjsax Apr 28, 2026
faa8b48
KAFKA-20533: Correcting error response for topic deletion during shar…
apoorvmittal10 Apr 28, 2026
8a1c198
KAFKA-20366: Add syntax highlighting in security docs (#21965)
gomudayya Apr 29, 2026
cb7e3ab
KAFKA-20410: Register topic DLQ configs in LogConfig. [2/N] (#22167)
smjn Apr 29, 2026
5645518
KAFKA-20542 : Fix aggregatedJavadocs build failure (#22172)
muralibasani Apr 29, 2026
4bb8f0f
MINOR: Fix duplicate args in KStreamSessionWindowAggregateProcessorTe…
aliehsaeedii Apr 30, 2026
474798a
KAFKA-20072: Don't generate IDs with hyphens (#21313)
wernerdv Apr 30, 2026
22c1e44
MINOR: Include numeric bound in group config validation errors (#22185)
dajac Apr 30, 2026
be36bab
KAFKA-20536 Fix empty heading - Adding upgrade instructions for 4.1 -…
muralibasani Apr 30, 2026
b047948
MINOR: Add docs for KIP-1035 (#22161)
bbejeck May 1, 2026
10805c9
KAFKA-20297 Move SecurityUtils, ConfigUtils, LogContext, AppInfoParse…
mingyen066 May 1, 2026
2e0596d
MINOR: Migrate ProduceRequestTest to server module (#22124)
yunchipang May 1, 2026
ff2ba93
KAFKA-13022 Optimize ClientQuotasImage#describe (#19079)
FrankYang0529 May 1, 2026
f9037bc
KAFKA-19700 : remove flaky testDescribeStreamsGroupWithShortTimeout t…
muralibasani May 1, 2026
c72fcda
MINOR: Cleanup TestUtils.scala (#22091)
m1a2st May 2, 2026
162b3a1
MINOR: Fix various typos and formatting issues across multiple module…
Ladsgroup May 2, 2026
b563238
MINOR: Add tests for RaftVoterEndpoint (#22195)
kuoche1712003 May 3, 2026
de38d89
MINOR: Rewrite DefaultApiVersionManagerTest from Scala to Java and mo…
JiayaoS May 4, 2026
937add8
MINOR: Avoid eager readNextOffset() call in Cleaner.cleanSegments (#2…
kuoche1712003 May 4, 2026
6be48c6
KAFKA-20441: Fix handling of cordoned log dirs (#22070)
mimaison May 4, 2026
94b6886
KAFKA-13499: Avoid restoring outdated records (#22115)
gabriellefu May 4, 2026
230e2c2
KAFKA-19042 Rewrite TransactionsTest from Scala to Java (#22150)
m1a2st May 5, 2026
ab14d10
MINOR: Upgrade bouncycastle to 1.84 (#22194)
dejan2609 May 5, 2026
e6df92f
KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnecti…
chickenchickenlove May 5, 2026
9c106dc
KAFKA-15918: Fix flaky test OffsetsApiIntegrationTest.testResetSinkCo…
Shekharrajak May 5, 2026
e0e7323
KAFKA-15768: Fix getOnlyPartitionResult to handle FailedQueryResult (…
suzhiking May 5, 2026
366d495
KAFKA-18563 move RaftClientTestContext RpcVersion methods into RaftPr…
FrankYang0529 May 5, 2026
81460c8
KAFKA-20546 Lazily call generateNewClientId when handling GetTelemetr…
YutaLin May 5, 2026
10dc441
KAFKA-19009 Move MetadataCacheTest to metadata module (#22118)
FrankYang0529 May 5, 2026
c7b6797
KAFKA-20435: Move LogManagerTest to storage module (#22139)
mimaison May 5, 2026
7562044
KAFKA-20444: [1/N] Add TxnOffsetCommit v6 schema (KIP-1319) (#22205)
dajac May 5, 2026
03e9e30
KAFKA-20372: Fix flaky test in NamedTopologyIntegrationTest (#21968)
chickenchickenlove May 5, 2026
bbd81e8
KAFKA-20549: Share group DLQ manager implementation. Skeleton classes…
smjn May 5, 2026
72e380c
KAFKA-20380; backwards compatible advertised.listeners when it is not…
kevin-wu24 May 5, 2026
3b6c838
MINOR: Move client test utilities to test fixtures and resolve shadow…
soarez May 5, 2026
38227ab
KAFKA-20551: Remove unnecessary generics from TxnOffsetCommitResponse…
JiayaoS May 6, 2026
7238479
KAFKA-20444: [2/N] Update OffsetMetadataManager to use new TxnOffsetC…
dajac May 6, 2026
42b4087
MINOR: Fixed documentation on formatting new brokers (#21981)
ppatierno May 6, 2026
cdc9eb2
KAFKA-20245: DLQ records exceeding max delivery count. [3/N] (#22080)
smjn May 6, 2026
2342c80
KAFKA-20444: [3/N] Allow building TxnOffsetCommit v6 requests with to…
dajac May 6, 2026
5e6150c
HOTFIX: Fix SharePartition build error (#22222)
m1a2st May 6, 2026
85c7227
MINOR: fix DynamicBrokerReconfigurationTest (#22226)
mjsax May 6, 2026
3873dad
KAFKA-20555: Use jakarta.annotation.Priority in JaasBasicAuthFilter (…
mimaison May 7, 2026
7054bf2
MINOR: Removed stale Javadoc comment (#22227)
ppatierno May 7, 2026
baa064e
KAFKA-20444: [4/N] Prepare TxnOffsetCommitResponse for topic IDs (KIP…
dajac May 7, 2026
1314d35
MINOR: Fix Punctuator Javadocs for old and new ProcessorContext refer…
suzhiking May 7, 2026
e937664
KAFKA-20523: Fix logger class name in KStreamKTableJoinProcessor (#22…
suzhiking May 7, 2026
7480345
KAFKA-20452 Avoid creating unnecessary empty batches in LogCleaner be…
JiayaoS May 8, 2026
25d0906
MINOR: Move testCallInFlightTimeouts to Java and remove internal fact…
JiayaoS May 8, 2026
26b6634
MINOR: Fix misleading log message when lastOffset < firstOffset in Sh…
majialoong May 8, 2026
c9a5f86
MINOR: Migrate controllerSocketTimeoutMs from KafkaConfig to Abstract…
yunchipang May 8, 2026
6a1c8b4
KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.c…
m1a2st May 8, 2026
5b334f6
KAFKA-20193: Remove unused code (#21539)
asknishant May 8, 2026
d5efe55
KAFKA-20558 NPE ClusterInstance.waitUntilLeaderIsElectedOrChanged (#2…
soarez May 9, 2026
5463b69
KAFKA-20553 Eliminate the dependencies on "sourceSets.test.output" (S…
m1a2st May 9, 2026
b033b2e
KAFKA-20114: Fix producer ID retry backoff race (#22204)
chickenchickenlove May 9, 2026
06d42a2
MINOR: Optimize `describeConfigs` queries and address cleanups for `C…
Rancho-7 May 9, 2026
ae03a1e
MINOR: Fix outdated Javadoc link in AuthorizableRequestContext (#22230)
JiayaoS May 9, 2026
7accdc8
KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for …
muralibasani May 10, 2026
319dd61
KAFKA-20444: [5/N] Resolve TxnOffsetCommit topic IDs in KafkaApis (KI…
dajac May 10, 2026
7f58618
KAFKA-20444: [6/N] Handle GROUP_ID_NOT_FOUND and STALE_MEMBER_EPOCH i…
dajac May 10, 2026
4bb5d39
MINOR: Use testFixturesImplementation instead of testFixturesApi (#22…
m1a2st May 10, 2026
4522654
KAFKA-20550 Rename OffsetsUtils to GroupOffsetsResetter (#22207)
majialoong May 10, 2026
85be169
KAFKA-20444: [7/N] Wire topic IDs through OffsetMetadataManager (KIP-…
dajac May 11, 2026
c717e6e
MINOR: Clean up OffsetCommit request/response validation tests in Kaf…
dajac May 11, 2026
7b7fae7
MINOR: Convert GroupOffsetsResetterOptions to record (#22251)
majialoong May 11, 2026
ab88df7
KAFKA-20535: Improve async consumer CPU usage under low max.poll.reco…
chickenchickenlove May 11, 2026
95c2187
KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for …
m1a2st May 12, 2026
62db165
KAFKA-20444: [8/N] Extend TxnOffsetCommit integration tests to v6 (KI…
dajac May 12, 2026
8889765
KAFKA-20549: Intd new cache helper interface for DLQ manager. [2/N] (…
smjn May 12, 2026
4228890
MINOR: follow-up of KAFKA-20317 (#22171)
frankvicky May 12, 2026
256f536
MINOR: Rewrite LogCleanerTest in Java and move it to storage module (…
majialoong May 12, 2026
d5e8b9c
KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for …
muralibasani May 12, 2026
a48ef25
KAFKA-20572 Fix NPE when using listener-prefixed SSL configs (#22269)
hgeraldino May 13, 2026
d1a05f9
KAFKA-20571: Added store unwrapping for publishing num-keys metric. (…
Nikita-Shupletsov May 13, 2026
7a64fe8
MINOR: Publish kafka-clients test-fixtures artifact (#22275)
majialoong May 13, 2026
90703da
KAFKA-20553 Eliminate the dependencies on "sourceSets.test.output" (r…
unknowntpo May 13, 2026
6de42dc
MINOR: Fix race in StreamsGroupHeartbeatRequestTest testDynamicGroupC…
squah-confluent May 14, 2026
eb96d7c
KAFKA-20563: Fix flaky ShareConsumerRackAwareTest (#22268)
AndrewJSchofield May 14, 2026
7c3dd41
KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for …
muralibasani May 14, 2026
a4cec15
MINOR: Rewrite RaftClusterSnapshotTest from Scala to Java (#22116)
JiayaoS May 14, 2026
81b1bf3
MINOR: Fix documentation typos in protocol and upgrade guides (#22262)
arpitjain099 May 14, 2026
afed4b8
KAFKA-20440: Use default Keystore type instead of hardcoding PKCS12 k…
scholzj May 14, 2026
4ef1ff8
KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for …
m1a2st May 14, 2026
36d052b
MINOR: Move LogOffsetTest to server module and rewrite in Java (#22121)
majialoong May 15, 2026
dc3fcbb
KAFKA-20443 Move RequestChannel Requests to server module (#22075)
mimaison May 15, 2026
979fcc3
KAFKA-20574 SimpleConfigRepository in the storage module could be rep…
muralibasani May 15, 2026
2768948
KAFKA-20575: Add onPartitionsLost support for MockConsume (#22273)
adikou May 15, 2026
b64498a
KAFKA-20549: Add logic for create topic in DLQ state manager. [3/N] (…
smjn May 15, 2026
f4d38b9
KAFKA-20564 Move AuthorizerTest to server (#22261)
mimaison May 15, 2026
1695e95
KAFKA-20419 : Add SASL_PLAINTEXT docker compose examples and sanity t…
muralibasani May 15, 2026
99611aa
KAFKA-20496: Add isolation level to IQ dispatch (#22143)
nicktelford May 15, 2026
58819e1
KAFKA-20492: Prepare DBAccessor for txn support (#22142)
nicktelford May 15, 2026
6c83a29
KAFKA-20489: Add enable.transactional.statestores (#22141)
nicktelford May 15, 2026
9505119
MINOR: Use NullNode instead of empty TextNode for missing request/res…
majialoong May 15, 2026
9dfc5a7
MINOR: Prefer MetadataRecordSerde.INSTANCE over new instances (#22289)
JiayaoS May 16, 2026
16306d9
KAFKA-20592 Fix typos in Streams documentation (#22299)
akhil-sabu-ibm May 17, 2026
db39865
KAFKA-20566: Improve logging in share coordinator (#22257)
AndrewJSchofield May 17, 2026
db6b5af
KAFKA-20549: Change ownership of DLQ state manager. [4/N] (#22300)
smjn May 17, 2026
55a9d40
KAFKA-17689 Change TieredStorageTestContext to use ClusterInstance (#…
FrankYang0529 May 18, 2026
c8e9464
MINOR: Update javadocs for GroupConfig and GroupConfigManager (#21771)
squah-confluent May 18, 2026
2ed663e
MINOR: some code cleanup (#22288)
mjsax May 18, 2026
d55e0cb
KAFKA-20545: Fix flaky MirrorConnectorsIntegrationSSLTest testConnect…
nileshkumar3 May 18, 2026
c58ce9c
MINOR: Add javadoc to share coord member fields and jobs. (#22305)
smjn May 18, 2026
164256f
KAFKA-20569 Add upgrade instructions for 4.2 and 4.3 (#22263)
mimaison May 18, 2026
98ed67e
MINOR: Prevent this leak while DefaultStatePersister construction (#2…
smjn May 18, 2026
68a8d45
MINOR: Fixed metrics decompression (#22327)
apoorvmittal10 May 19, 2026
159d696
KAFKA-20565 Fix flaky test testAutoCommitSentBeforePositionUpdate tim…
muralibasani May 20, 2026
540f638
MINOR: Fix typo in TransactionContext javadoc (#22321)
RonGamzu May 20, 2026
4fc0a30
KAFKA-18766: Clarify allow.everyone.if.no.acl.found in ACL docs (#22287)
Hana1025 May 20, 2026
ac031bb
KAFKA-4320: Clarify log compaction configuration docs (#22304)
Derekko-web May 20, 2026
ee2673c
KAFKA-18810 fix flaky ClientIdQuotaTest.testQuotaOverrideDelete (#22329)
muralibasani May 21, 2026
a7dfb89
KAFKA-20409: Don't expose internal group configs unless they are user…
majialoong May 21, 2026
8c079f4
KAFKA-17689 Migrate TieredStorageTestHarness to new test infra (Alter…
m1a2st May 21, 2026
23436ab
KAFKA-19620 Move AutoTopicCreationManager to server module (#20383)
brandboat May 21, 2026
5d86a6b
MINOR: Remove unnecessary null check in DefaultStatePersister#stop (#…
kuoche1712003 May 21, 2026
f7dbf0b
KAFKA-20570: Catch RuntimeException in ConsumerProtocol deserializati…
dongnuo123 May 21, 2026
c5f16d2
KAFKA-18087 Revert unnecessary integration testing of both consumer g…
muralibasani May 22, 2026
edcada2
KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KI…
jiafu1115 May 22, 2026
9be8ca1
KAFKA-17689 Migrate ReassignReplicaMoveTest and ReassignReplicaExpand…
majialoong May 23, 2026
6112e3f
MINOR: Correct the variable name in remote storage's test (#22349)
jiafu1115 May 23, 2026
1bcb231
MINOR: Fix typo in DynamicBrokerConfigTest (#22352)
FrankYang0529 May 23, 2026
2922b05
MINOR: Provide default no-op implementations for addReconfigurable an…
majialoong May 24, 2026
80f6bdd
KAFKA-17689 Migrate TieredStorageTestHarness to new test infra (#22361)
TaiJuWu May 24, 2026
bc137fc
MINOR: Add hearbeat interval override to PerformanceServiceTest (#22360)
smjn May 24, 2026
fa097fa
KAFKA-20605 upgrade gradle action to enable the CI (#22362)
m1a2st May 24, 2026
75240f8
KAFKA-17689 Migrate DeleteTopicTest to to new test infra (#22370)
joshua2519 May 26, 2026
a562042
KAFKA-17689 Migrate ListOffsetsTest to new test infra (#22369)
unknowntpo May 26, 2026
2da5418
KAFKA-16876: TaskManager.handleRevocation doesn't handle errors throw…
gabriellefu May 26, 2026
fd1a1aa
KAFKA-20335: Document KIP-1271 headers-aware state stores (#21840)
nileshkumar3 May 27, 2026
c298d4b
MINOR: Add 4.3.0 to system tests (#22373)
mimaison May 27, 2026
0e37eff
MINOR: Add 4.3.0 to core system tests (#22381)
mimaison May 27, 2026
be8e1ec
MINOR: Remove outdated note for streams group protocol (#22374)
UladzislauBlok May 27, 2026
89f3888
KAFKA-20444: [9/N] Preserve topic-level structure in TxnOffsetCommit …
dajac May 27, 2026
df49f94
MINOR: Add documentation for the num-keys metric introduced by KIP-12…
ezhou413 May 27, 2026
3fcf9f1
KAFKA-17689 Migrate Disable/EnableRemoteLogOnTopicTest to new test in…
johnny94 May 27, 2026
e0456d1
KAFKA-17871: avoid blocking the herder thread when producer flushing …
davide-armand May 27, 2026
c0041e9
KAFKA-17689 Migrate ReassignReplicaShrinkTest and RollAndOffloadActiv…
brandboat May 27, 2026
78a66fa
KAFKA-19648; Cluster metadata bootstrapping with kraft checkpoint (#2…
mannoopj May 27, 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
  •  
  •  
  •  
The diff you're trying to view is too large. We only load the first 3000 changed files.
44 changes: 37 additions & 7 deletions .asf.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -15,14 +15,44 @@
# specific language governing permissions and limitations
# under the License.

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

notifications:
commits: commits@kafka.apache.org
issues: jira@kafka.apache.org
commits: commits@kafka.apache.org
issues: jira@kafka.apache.org
pullrequests: jira@kafka.apache.org
jira_options: link label

jenkins:
github_whitelist:
- ConcurrencyPractitioner
- ableegoldman
- cadonna
github:
description: "Apache Kafka - A distributed event streaming platform"
homepage: https://kafka.apache.org/
labels:
- java
- scala
- kafka
- streaming

# 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
collaborators:
- brandboat
- chirag-wadhwa5
- DL1231
- m1a2st
- mingyen066
- Rancho-7
- sjhajharia
- smjn
- TaiJuWu
- Yunyung
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@0723195856401067f7a2779048b490ace7a47d7c # v5.0.2
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