mirror of https://github.com/apache/kafka.git
KAFKA-19748: Add a note in docs about memory leak in Kafka Streams 4.1.0 (#20639)
ci.yml #633:Commit
f5a87b3703
pushed by
root
MINOR: Adjust the timing for creating connect config (#20612)
ci.yml #629:Commit
24cad50840
pushed by
root
KAFKA-19719 --no-initial-controllers should not assume kraft.version=… (#20616)
ci.yml #628:Commit
099e91f5fc
pushed by
root
MINOR: Enable streams rebalance protocol in EosIntegrationTest (#20592)
generate-reports.yml #627:Scheduled
MINOR: Enable streams rebalance protocol in EosIntegrationTest (#20592)
docker_scan.yml #626:Scheduled
MINOR: Enable streams rebalance protocol in EosIntegrationTest (#20592)
pr-labels-cron.yml #625:Scheduled
MINOR: Enable streams rebalance protocol in EosIntegrationTest (#20592)
ci.yml #624:Commit
611f4128b4
pushed by
root
MINOR: Fix a minor copy&paste typo in comments (#20634)
ci.yml #622:Commit
d76442e5a6
pushed by
root
KAFKA-19748: fix metrics leak in Kafka Streams (#20633)
ci.yml #618:Commit
0dd8471174
pushed by
root
KAFKA-19748: fix metrics leak in Kafka Streams (#20633)
ci.yml #617:Commit
ce248ab0d6
pushed by
root
KAFKA-18185: remove internal.leave.group.on.close config (#19400)
generate-reports.yml #616:Scheduled
KAFKA-18185: remove internal.leave.group.on.close config (#19400)
ci.yml #615:Commit
68f1da8474
pushed by
root
KAFKA-19744: Move restore time calculation to ChangelogMetadata (#20613)
docker_scan.yml #614:Scheduled
KAFKA-19744: Move restore time calculation to ChangelogMetadata (#20613)
pr-labels-cron.yml #613:Scheduled
KAFKA-19744: Move restore time calculation to ChangelogMetadata (#20613)
ci.yml #611:Commit
28e7803037
pushed by
root
KAFKA-19467; Add a metric for controller thread idleness (#20422)
generate-reports.yml #610:Scheduled
KAFKA-19467; Add a metric for controller thread idleness (#20422)
ci.yml #609:Commit
8468317dac
pushed by
root
KAFKA-19690 Add epoch check before verification guard check to prevent unexpected fatal error (#20618)
ci.yml #608:Commit
a10c1f3ea1
pushed by
root
KAFKA-9825 Kafka protocol BNF format should have some way to display tagged fields (#20536)
docker_scan.yml #607:Scheduled
KAFKA-9825 Kafka protocol BNF format should have some way to display tagged fields (#20536)
pr-labels-cron.yml #606:Scheduled
KAFKA-9825 Kafka protocol BNF format should have some way to display tagged fields (#20536)
ci.yml #605:Commit
33cd114375
pushed by
root
MINOR: Typo in ListShareGroupOffsetsResults javadoc (#20623)
ci.yml #603:Commit
7f65b1fa96
pushed by
root
KAFKA-19692 improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions (#20555)
docker_scan.yml #600:Scheduled
KAFKA-19692 improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions (#20555)
pr-labels-cron.yml #599:Scheduled
KAFKA-19692 improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions (#20555)
generate-reports.yml #598:Scheduled
KAFKA-19692 improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions (#20555)
ci.yml #597:Commit
423330ebe7
pushed by
root
KAFKA-19719 --no-initial-controllers should not assume kraft.version=1 (#20604)
ci.yml #596:Commit
012e4ca6d8
pushed by
root
KAFKA-19739 Upgrade commons-validator to 1.10.0 (#20601)
ci.yml #589:Commit
3c0843961b
pushed by
root
MINOR: Remove logContext arrtibute from StreamsGroup and CoordinatorRuntime (#20572)
ci.yml #588:Commit
c2aeec46a2
pushed by
root
KAFKA-19732, KAFKA-19716: Clear out coordinator snapshots periodically while loading (#20590)
ci.yml #586:Commit
8248d1d2bb
pushed by
root
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
ci.yml #585:Scheduled
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
docker_scan.yml #584:Scheduled
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
generate-reports.yml #583:Scheduled
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
pr-labels-cron.yml #582:Scheduled
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
generate-reports.yml #581:Scheduled
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
docker_scan.yml #580:Scheduled
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
pr-labels-cron.yml #579:Scheduled
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
ci.yml #578:Commit
ea771563e0
pushed by
root
KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement (#20286)
generate-reports.yml #577:Scheduled
KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement (#20286)
docker_scan.yml #576:Scheduled
KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement (#20286)
pr-labels-cron.yml #575:Scheduled
KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement (#20286)
ci.yml #574:Scheduled
KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement (#20286)
ci.yml #573:Commit
05d71ad1a8
pushed by
root
KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
generate-reports.yml #572:Scheduled
KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
docker_scan.yml #571:Scheduled
KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
pr-labels-cron.yml #570:Scheduled
KAFKA-19529: State updater sensor names should be unique (#20262) (#20274)
ci.yml #569:Commit
0179193b75
pushed by
root
KAFKA-19529: State updater sensor names should be unique (#20262) (#20273)
ci.yml #568:Commit
deb58910c8
pushed by
root
KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
ci.yml #567:Scheduled
KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
ci.yml #566:Commit
e1f45218c9
pushed by
root
MINOR: add test for `kafka-consumer-groups.sh` should not fail when partition offline (#20235)
generate-reports.yml #565:Scheduled
MINOR: add test for `kafka-consumer-groups.sh` should not fail when partition offline (#20235)
docker_scan.yml #564:Scheduled
MINOR: add test for `kafka-consumer-groups.sh` should not fail when partition offline (#20235)
pr-labels-cron.yml #563:Scheduled
MINOR: add test for `kafka-consumer-groups.sh` should not fail when partition offline (#20235)
ci.yml #562:Commit
dfaf9f9cf7
pushed by
root
KAFKA-19529: State updater sensor names should be unique (#20262)
ci.yml #561:Commit
44c6e956ed
pushed by
root
MINOR: Fix duplicate 'to' in ExactlyOnceMessageProcessor javadoc (#20228)
ci.yml #560:Commit
dda1b5a4e8
pushed by
root
KAFKA-19489; Extra validation when formatting a node (#20136)
ci.yml #556:Commit
1bcaa19c46
pushed by
root
KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline (#20218)
generate-reports.yml #554:Scheduled
KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline (#20218)
docker_scan.yml #553:Scheduled
KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline (#20218)
pr-labels-cron.yml #552:Scheduled
KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline (#20218)
ci.yml #551:Commit
96c8e86cdf
pushed by
root
MINOR: Delete the redundant feature upgrade instruction for running KIP-1071 EA (#20250)
ci.yml #550:Commit
9c83c6d1f3
pushed by
root
KAFKA-18066: Fix mismatched StreamThread ID in log messages (#19517)
ci.yml #549:Commit
f9ccf83a7f
pushed by
root
KAFKA-12281: Deprecate BrokerNotFoundException (#20192)
ci.yml #548:Commit
de2adb69de
pushed by
root
KAFKA-19551: Remove the handling of FatalExitError in RemoteStorageThreadPool (#20245)
generate-reports.yml #547:Scheduled
KAFKA-19551: Remove the handling of FatalExitError in RemoteStorageThreadPool (#20245)
docker_scan.yml #546:Scheduled
KAFKA-19551: Remove the handling of FatalExitError in RemoteStorageThreadPool (#20245)
pr-labels-cron.yml #545:Scheduled
KAFKA-19551: Remove the handling of FatalExitError in RemoteStorageThreadPool (#20245)
ci.yml #544:Commit
dfced692d2
pushed by
root
KAFKA-19471: Enable acknowledgement for a record which could not be deserialized (#20148)
generate-reports.yml #543:Scheduled
KAFKA-19471: Enable acknowledgement for a record which could not be deserialized (#20148)
ci.yml #542:Commit
abbb6b3c13
pushed by
root
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
docker_scan.yml #541:Scheduled
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
pr-labels-cron.yml #540:Scheduled
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
generate-reports.yml #539:Scheduled
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
docker_scan.yml #538:Scheduled
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
pr-labels-cron.yml #537:Scheduled
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
ci.yml #536:Scheduled
MINOR: Improve Kafka Streams Protocol Upgrade Doc (#20241)
ci.yml #535:Commit
1d4b22bc3e
pushed by
root
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
generate-reports.yml #534:Scheduled
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
ci.yml #533:Commit
73f195f062
pushed by
root
MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap (#20205)
docker_scan.yml #532:Scheduled
MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap (#20205)
pr-labels-cron.yml #531:Scheduled
KAFKA-17645 Enable warmup in producer performance test (KIP-1052) (#17340)
ci.yml #525:Commit
fba01c42c8
pushed by
root
KAFKA-18265: Move inflight batch and state classes from SharePartition (2/N) (#20230)
ci.yml #524:Commit
d350f603a4
pushed by
root
KAFKA-19523: Gracefully handle error while building remoteLogAuxState (#20201)
generate-reports.yml #523:Scheduled
KAFKA-19523: Gracefully handle error while building remoteLogAuxState (#20201)
docker_scan.yml #522:Scheduled
KAFKA-19523: Gracefully handle error while building remoteLogAuxState (#20201)
pr-labels-cron.yml #521:Scheduled
KAFKA-19523: Gracefully handle error while building remoteLogAuxState (#20201)
ci.yml #520:Commit
93adaea599
pushed by
root
KAFKA-19525: Refactor TopicBasedRLMM implementation to remove unused code (#20204)
ci.yml #519:Commit
16c079ed23
pushed by
root
KAFKA-19272: Add initPid Response handling when keepPrepared is set to true (KIP-939) (#20039)
ci.yml #518:Commit
c7e4ff01cd
pushed by
root
KAFKA-19501 Update OpenJDK base image from buster to bullseye (#20165)
ci.yml #517:Commit
d5a3acda89
pushed by
root
KAFKA-19501 Update OpenJDK base image from buster to bullseye (#20165)
ci.yml #516:Commit
74d93adadb
pushed by
root
MINOR: Change log level for cold snapshot log. (#20209)
ci.yml #510:Commit
6ef675d08b
pushed by
root
KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N) (#20207)
docker_scan.yml #509:Scheduled
KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N) (#20207)
pr-labels-cron.yml #508:Scheduled
KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N) (#20207)
ci.yml #507:Commit
f52f2b99e5
pushed by
root
MINOR: Add tests on TxnOffsetCommit and EndTxnMarker protection against invalid producer epoch when TV2 is used (#20024)
ci.yml #505:Commit
50598191dc
pushed by
root
MINOR: Move ClientQuotasRequestTest to server module (#20053)
ci.yml #503:Commit
9a2f202a1e
pushed by
root
KAFKA-19522: avoid electing fenced lastKnownLeader (#20200)
ci.yml #500:Commit
c162d2eb14
pushed by
root
KAFKA-19522: avoid electing fenced lastKnownLeader (#20200)
ci.yml #499:Commit
e4e2dce2eb
pushed by
root
MINOR: Remove unnecessary dependencies from coordinator-common (follow up to pr#20089) (#20194)
docker_scan.yml #496:Scheduled
MINOR: Remove unnecessary dependencies from coordinator-common (follow up to pr#20089) (#20194)
pr-labels-cron.yml #495:Scheduled
MINOR: Remove unnecessary dependencies from coordinator-common (follow up to pr#20089) (#20194)
ci.yml #494:Scheduled
MINOR: Remove unnecessary dependencies from coordinator-common (follow up to pr#20089) (#20194)
ci.yml #493:Commit
1b351ad6e2
pushed by
root
KAFKA-19520 Bump Commons-Lang for CVE-2025-48924 (#20196)
ci.yml #492:Commit
01d8154b6e
pushed by
root
KAFKA-19520 Bump Commons-Lang for CVE-2025-48924 (#20196)
ci.yml #491:Commit
12e695e298
pushed by
root
KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted (#20187)
ci.yml #490:Commit
38e3359446
pushed by
root
MINOR: Correct RemoteLogManager.getLeaderEpochEntries comment (#20181)
generate-reports.yml #489:Scheduled
MINOR: Correct RemoteLogManager.getLeaderEpochEntries comment (#20181)
docker_scan.yml #488:Scheduled
MINOR: Correct RemoteLogManager.getLeaderEpochEntries comment (#20181)
ci.yml #487:Commit
9b542b6ea2
pushed by
root
KAFKA-19509: Improve error message when release version is wrong (#20185)
pr-labels-cron.yml #486:Scheduled
KAFKA-19509: Improve error message when release version is wrong (#20185)
ci.yml #484:Commit
9572d19c59
pushed by
root
KAFKA-19441: encapsulate MetadataImage in GroupCoordinator/ShareCoordinator (#20061)
ci.yml #483:Commit
f81853ca88
pushed by
root
MINOR: Migrate CoordinatorLoaderImpl from Scala to Java (#20089)
generate-reports.yml #482:Scheduled
MINOR: Migrate CoordinatorLoaderImpl from Scala to Java (#20089)
ci.yml #479:Commit
d03878c7fb
pushed by
root
MINOR: Revert "KAFKA-18913: Start state updater in task manager (#198… (#20186)
ci.yml #478:Commit
eb155a2113
pushed by
root
KAFKA-19377:Update /streams/developer-guide/security.html for KIP-1071 (#20084)
ci.yml #477:Commit
e8e4e0b6db
pushed by
root
KAFKA-19501 Update OpenJDK base image from buster to bullseye (#20165)
ci.yml #476:Commit
70824be92a
pushed by
root
KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)
generate-reports.yml #475:Scheduled
KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)
docker_scan.yml #474:Scheduled
KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)
pr-labels-cron.yml #473:Scheduled
KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)
ci.yml #472:Commit
e3276ae029
pushed by
root
KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)
ci.yml #471:Commit
05f012c7f1
pushed by
root
Cherrypick "MINOR : Handle error for client telemetry push (#19881)" (#20176)
ci.yml #470:Commit
70c51641fb
pushed by
root
MINOR: Add ShareFetch quota session verification test (#20164)
ci.yml #469:Commit
65a9337739
pushed by
root
MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR (#20174)
ci.yml #468:Commit
98cb8df7a5
pushed by
root
MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) (#20131)
generate-reports.yml #467:Scheduled
MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) (#20131)
docker_scan.yml #466:Scheduled
MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) (#20131)
pr-labels-cron.yml #465:Scheduled
MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) (#20131)
ci.yml #464:Commit
daece61a50
pushed by
root
KAFKA-19459: List internal topics for the user (#20157)
ci.yml #463:Commit
7ea32a0e93
pushed by
root
KAFKA-19504: Remove unused metrics reporter initialization in KafkaAdminClient (#20166)
ci.yml #462:Commit
dd82542493
pushed by
root
KAFKA-19504: Remove unused metrics reporter initialization in KafkaAdminClient (#20166)
ci.yml #461:Commit
f35f94b3e6
pushed by
root
KAFKA-19504: Remove unused metrics reporter initialization in KafkaAdminClient (#20166)
ci.yml #460:Commit
d95857a155
pushed by
root
KAFKA-19452: Fix flaky test LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments (#20121)
generate-reports.yml #459:Scheduled
KAFKA-19452: Fix flaky test LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments (#20121)
docker_scan.yml #458:Scheduled
KAFKA-19452: Fix flaky test LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments (#20121)
pr-labels-cron.yml #457:Scheduled
KAFKA-19452: Fix flaky test LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments (#20121)
ci.yml #456:Commit
a61a37f7dd
pushed by
root
MINOR: Moving the rollback out of lock in share partition (#20153)
generate-reports.yml #454:Scheduled
MINOR: Moving the rollback out of lock in share partition (#20153)
pr-labels-cron.yml #452:Scheduled
MINOR: Moving the rollback out of lock in share partition (#20153)
generate-reports.yml #451:Scheduled
MINOR: Moving the rollback out of lock in share partition (#20153)
pr-labels-cron.yml #449:Scheduled
MINOR: Moving the rollback out of lock in share partition (#20153)
generate-reports.yml #447:Scheduled
MINOR: Moving the rollback out of lock in share partition (#20153)
pr-labels-cron.yml #445:Scheduled
MINOR: Moving the rollback out of lock in share partition (#20153)
ci.yml #443:Commit
986322dc36
pushed by
root
KAFKA-19495: Update config for native image (v4.1.0) (#20151)
ci.yml #442:Commit
793294bd2e
pushed by
root
KAFKA-19485: Added check before sending acknowledgements on initial epoch. (#20135)
generate-reports.yml #440:Scheduled
KAFKA-19485: Added check before sending acknowledgements on initial epoch. (#20135)
docker_scan.yml #439:Scheduled
KAFKA-19485: Added check before sending acknowledgements on initial epoch. (#20135)
pr-labels-cron.yml #438:Scheduled
KAFKA-19485: Added check before sending acknowledgements on initial epoch. (#20135)
ci.yml #437:Commit
56a3c6dde9
pushed by
root
MINOR: Throw exceptions if source topic is missing (#20123)
ci.yml #434:Commit
c625b44d8c
pushed by
root