root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 5 Packages Projects Releases Wiki Activity
All Workflows build.yml ci-complete.yml ci.yml deflake.yml docker_build_and_test.yml docker_official_image_build_and_test.yml docker_promote.yml docker_rc_release.yml docker_scan.yml generate-reports.yml pr-labeled.yml pr-labels-cron.yml pr-linter.yml pr-reviewed.yml pr-update.yml prepare_docker_official_image_source.yml stale.yml workflow-requested.yml
Actor
All actors root
Status
All status success failure waiting running
KAFKA-19754: Add RPC-level integration test for StreamsGroupDescribeRequest (#20632)
#635:Commit 2938c4242e pushed by root
trunk
2025-10-07 23:15:01 +08:00
0s
KAFKA-19436: Restrict cache update for ongoing batch/offset state (#20041) (#20647)
#634:Commit 978672b724 pushed by root
4.1
2025-10-07 23:15:00 +08:00
0s
KAFKA-19748: Add a note in docs about memory leak in Kafka Streams 4.1.0 (#20639)
#633:Commit f5a87b3703 pushed by root
trunk
2025-10-07 23:15:01 +08:00
0s
MINOR: Adjust the timing for creating connect config (#20612)
#629:Commit 24cad50840 pushed by root
trunk
2025-10-07 06:55:01 +08:00
0s
KAFKA-19719 --no-initial-controllers should not assume kraft.version=… (#20616)
#628:Commit 099e91f5fc pushed by root
4.0
2025-10-08 04:04:20 +08:00
0s
MINOR: Enable streams rebalance protocol in EosIntegrationTest (#20592)
#624:Commit 611f4128b4 pushed by root
trunk
2025-10-06 22:44:56 +08:00
0s
MINOR: Fix a minor copy&paste typo in comments (#20634)
#622:Commit d76442e5a6 pushed by root
trunk
2025-10-05 22:14:54 +08:00
0s
KAFKA-19748: fix metrics leak in Kafka Streams (#20633)
#619:Scheduled
trunk
2025-10-05 05:54:52 +08:00
0s
KAFKA-19748: fix metrics leak in Kafka Streams (#20633)
#618:Commit 0dd8471174 pushed by root
trunk
2025-10-05 00:00:21 +08:00
0s
KAFKA-19748: fix metrics leak in Kafka Streams (#20633)
#617:Commit ce248ab0d6 pushed by root
4.1
2025-10-05 16:04:29 +08:00
0s
KAFKA-18185: remove internal.leave.group.on.close config (#19400)
#615:Commit 68f1da8474 pushed by root
trunk
2025-10-04 13:34:52 +08:00
0s
KAFKA-19744: Move restore time calculation to ChangelogMetadata (#20613)
#612:Scheduled
trunk
2025-10-04 05:24:59 +08:00
0s
KAFKA-19744: Move restore time calculation to ChangelogMetadata (#20613)
#611:Commit 28e7803037 pushed by root
trunk
2025-10-04 00:00:23 +08:00
0s
KAFKA-19467; Add a metric for controller thread idleness (#20422)
#609:Commit 8468317dac pushed by root
trunk
2025-10-03 13:04:52 +08:00
0s
KAFKA-19690 Add epoch check before verification guard check to prevent unexpected fatal error (#20618)
#608:Commit a10c1f3ea1 pushed by root
4.1
2025-10-04 10:04:24 +08:00
0s
KAFKA-9825 Kafka protocol BNF format should have some way to display tagged fields (#20536)
#605:Commit 33cd114375 pushed by root
trunk
2025-10-03 04:55:01 +08:00
0s
MINOR: Typo in ListShareGroupOffsetsResults javadoc (#20623)
#603:Commit 7f65b1fa96 pushed by root
trunk
2025-10-02 20:44:54 +08:00
0s
[MINOR] Cleaning ignored streams test (#20583)
#602:Commit ea3d231185 pushed by root
4.1
2025-10-03 04:55:00 +08:00
0s
[MINOR] Cleaning ignored streams test (#20584)
#601:Commit f181048e42 pushed by root
4.0
2025-10-03 10:04:20 +08:00
0s
KAFKA-19692 improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions (#20555)
#597:Commit 423330ebe7 pushed by root
trunk
2025-10-02 04:04:25 +08:00
0s
KAFKA-19719 --no-initial-controllers should not assume kraft.version=1 (#20604)
#596:Commit 012e4ca6d8 pushed by root
4.1
2025-10-02 04:04:25 +08:00
0s
KAFKA-15873: Filter topics before sorting (#19304)
#591:Commit d1a821226c pushed by root
trunk
2025-10-01 03:54:57 +08:00
0s
KAFKA-19739 Upgrade commons-validator to 1.10.0 (#20601)
#589:Commit 3c0843961b pushed by root
trunk
2025-09-30 03:25:04 +08:00
0s
MINOR: Remove logContext arrtibute from StreamsGroup and CoordinatorRuntime (#20572)
#588:Commit c2aeec46a2 pushed by root
trunk
2025-09-29 19:14:53 +08:00
0s
MINOR: Cleanups in ops docs (#20532)
#587:Commit f4ce123505 pushed by root
4.1
2025-09-30 16:05:27 +08:00
0s
KAFKA-19732, KAFKA-19716: Clear out coordinator snapshots periodically while loading (#20590)
#586:Commit 8248d1d2bb pushed by root
4.0
2025-09-30 16:05:26 +08:00
0s
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
#585:Scheduled
trunk
2025-09-29 11:11:23 +08:00
0s
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
#578:Commit ea771563e0 pushed by root
trunk
2025-09-29 10:04:22 +08:00
0s
KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement (#20286)
#574:Scheduled
#18935/merge
2025-08-04 04:30:21 +08:00
0s
KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement (#20286)
#573:Commit 05d71ad1a8 pushed by root
trunk
2025-08-03 10:44:53 +08:00
0s
KAFKA-19529: State updater sensor names should be unique (#20262) (#20274)
#569:Commit 0179193b75 pushed by root
4.1
2025-08-03 04:33:16 +08:00
0s
KAFKA-19529: State updater sensor names should be unique (#20262) (#20273)
#568:Commit deb58910c8 pushed by root
4.0
2025-08-03 04:33:13 +08:00
0s
KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
#567:Scheduled
trunk
2025-08-02 08:40:34 +08:00
0s
KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
#566:Commit e1f45218c9 pushed by root
trunk
2025-08-02 00:00:11 +08:00
0s
MINOR: add test for `kafka-consumer-groups.sh` should not fail when partition offline (#20235)
#562:Commit dfaf9f9cf7 pushed by root
trunk
2025-08-01 09:37:53 +08:00
0s
KAFKA-19529: State updater sensor names should be unique (#20262)
#561:Commit 44c6e956ed pushed by root
trunk
2025-08-01 00:26:15 +08:00
0s
MINOR: Fix duplicate 'to' in ExactlyOnceMessageProcessor javadoc (#20228)
#560:Commit dda1b5a4e8 pushed by root
trunk
2025-07-31 15:48:04 +08:00
0s
KAFKA-19489; Extra validation when formatting a node (#20136)
#556:Commit 1bcaa19c46 pushed by root
trunk
2025-07-31 07:27:22 +08:00
0s
MINOR: Remove duplicated code in PgeViewDemo (#20252)
#555:Commit 81bdf0b889 pushed by root
trunk
2025-07-30 23:10:31 +08:00
0s
KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline (#20218)
#551:Commit 96c8e86cdf pushed by root
trunk
2025-07-30 06:50:18 +08:00
0s
MINOR: Delete the redundant feature upgrade instruction for running KIP-1071 EA (#20250)
#550:Commit 9c83c6d1f3 pushed by root
4.1
2025-07-31 04:30:59 +08:00
0s
KAFKA-18066: Fix mismatched StreamThread ID in log messages (#19517)
#549:Commit f9ccf83a7f pushed by root
trunk
2025-07-29 22:40:21 +08:00
0s
KAFKA-12281: Deprecate BrokerNotFoundException (#20192)
#548:Commit de2adb69de pushed by root
trunk
2025-07-29 14:30:37 +08:00
0s
KAFKA-19551: Remove the handling of FatalExitError in RemoteStorageThreadPool (#20245)
#544:Commit dfced692d2 pushed by root
trunk
2025-07-29 06:20:16 +08:00
0s
KAFKA-19471: Enable acknowledgement for a record which could not be deserialized (#20148)
#542:Commit abbb6b3c13 pushed by root
trunk
2025-07-28 22:10:18 +08:00
0s
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
#536:Scheduled
trunk
2025-07-28 04:30:07 +08:00
0s
MINOR: Improve Kafka Streams Protocol Upgrade Doc (#20241)
#535:Commit 1d4b22bc3e pushed by root
4.1
2025-07-27 22:30:11 +08:00
0s
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
#533:Commit 73f195f062 pushed by root
trunk
2025-07-27 00:00:16 +08:00
0s
MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap (#20205)
#530:Scheduled
#20008/merge
2025-07-27 04:30:11 +08:00
0s
Merge tag '4.0.1-rc0' into 4.0
#529:Commit 2a45b4f662 pushed by root
4.0
2025-07-26 04:30:12 +08:00
0s
MINOR: typo in javadoc (#20113)
#526:Commit 8614e15a28 pushed by root
trunk
2025-07-25 04:28:11 +08:00
0s
KAFKA-17645 Enable warmup in producer performance test (KIP-1052) (#17340)
#525:Commit fba01c42c8 pushed by root
trunk
2025-07-24 19:32:33 +08:00
0s
KAFKA-18265: Move inflight batch and state classes from SharePartition (2/N) (#20230)
#524:Commit d350f603a4 pushed by root
trunk
2025-07-24 18:42:53 +08:00
0s
KAFKA-19523: Gracefully handle error while building remoteLogAuxState (#20201)
#520:Commit 93adaea599 pushed by root
trunk
2025-07-24 09:59:25 +08:00
0s
KAFKA-19525: Refactor TopicBasedRLMM implementation to remove unused code (#20204)
#519:Commit 16c079ed23 pushed by root
trunk
2025-07-24 01:27:59 +08:00
0s
KAFKA-19272: Add initPid Response handling when keepPrepared is set to true (KIP-939) (#20039)
#518:Commit c7e4ff01cd pushed by root
trunk
2025-07-23 17:30:28 +08:00
0s
KAFKA-19501 Update OpenJDK base image from buster to bullseye (#20165)
#517:Commit d5a3acda89 pushed by root
4.1
2025-07-24 11:27:17 +08:00
0s
KAFKA-19501 Update OpenJDK base image from buster to bullseye (#20165)
#516:Commit 74d93adadb pushed by root
4.0
2025-07-24 11:27:17 +08:00
0s
KAFKA-19503: Deprecate MX4j support (#20208)
#512:Commit f5fcc4188f pushed by root
trunk
2025-07-23 07:33:19 +08:00
0s
MINOR: Change log level for cold snapshot log. (#20209)
#510:Commit 6ef675d08b pushed by root
trunk
2025-07-22 20:55:39 +08:00
0s
KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N) (#20207)
#507:Commit f52f2b99e5 pushed by root
trunk
2025-07-22 04:35:36 +08:00
0s
Bump version to 4.1.0
#506:Commit e14d849cbf pushed by root
4.1
2025-07-22 23:25:46 +08:00
0s
MINOR: Add tests on TxnOffsetCommit and EndTxnMarker protection against invalid producer epoch when TV2 is used (#20024)
#505:Commit 50598191dc pushed by root
trunk
2025-07-21 20:25:40 +08:00
0s
MINOR: Move ClientQuotasRequestTest to server module (#20053)
#503:Commit 9a2f202a1e pushed by root
trunk
2025-07-21 12:15:55 +08:00
0s
KAFKA-19522: avoid electing fenced lastKnownLeader (#20200)
#500:Commit c162d2eb14 pushed by root
trunk
2025-07-21 04:05:38 +08:00
0s
KAFKA-19522: avoid electing fenced lastKnownLeader (#20200)
#499:Commit e4e2dce2eb pushed by root
4.1
2025-07-21 20:25:38 +08:00
0s
MINOR: add a test for Protocol (#20169)
#497:Commit 908049fccc pushed by root
trunk
2025-07-20 19:55:35 +08:00
0s
MINOR: Remove unnecessary dependencies from coordinator-common (follow up to pr#20089) (#20194)
#494:Scheduled
trunk
2025-07-20 03:36:01 +08:00
0s
MINOR: Remove unnecessary dependencies from coordinator-common (follow up to pr#20089) (#20194)
#493:Commit 1b351ad6e2 pushed by root
trunk
2025-07-20 00:00:23 +08:00
0s
KAFKA-19520 Bump Commons-Lang for CVE-2025-48924 (#20196)
#492:Commit 01d8154b6e pushed by root
4.1
2025-07-20 19:55:32 +08:00
0s
KAFKA-19520 Bump Commons-Lang for CVE-2025-48924 (#20196)
#491:Commit 12e695e298 pushed by root
4.0
2025-07-20 23:25:28 +08:00
0s
KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted (#20187)
#490:Commit 38e3359446 pushed by root
trunk
2025-07-19 19:26:02 +08:00
0s
MINOR: Correct RemoteLogManager.getLeaderEpochEntries comment (#20181)
#487:Commit 9b542b6ea2 pushed by root
trunk
2025-07-19 11:15:42 +08:00
0s
KAFKA-19509: Improve error message when release version is wrong (#20185)
#485:Scheduled
trunk
2025-07-19 03:05:34 +08:00
0s
KAFKA-19509: Improve error message when release version is wrong (#20185)
#484:Commit 9572d19c59 pushed by root
trunk
2025-07-19 00:00:29 +08:00
0s
KAFKA-19441: encapsulate MetadataImage in GroupCoordinator/ShareCoordinator (#20061)
#483:Commit f81853ca88 pushed by root
trunk
2025-07-18 18:55:34 +08:00
0s
MINOR: Migrate CoordinatorLoaderImpl from Scala to Java (#20089)
#479:Commit d03878c7fb pushed by root
trunk
2025-07-18 10:45:38 +08:00
0s
MINOR: Revert "KAFKA-18913: Start state updater in task manager (#198… (#20186)
#478:Commit eb155a2113 pushed by root
4.1
2025-07-19 05:26:01 +08:00
0s
KAFKA-19377:Update /streams/developer-guide/security.html for KIP-1071 (#20084)
#477:Commit e8e4e0b6db pushed by root
trunk
2025-07-18 02:35:41 +08:00
0s
KAFKA-19501 Update OpenJDK base image from buster to bullseye (#20165)
#476:Commit 70824be92a pushed by root
trunk
2025-07-17 18:25:56 +08:00
0s
KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)
#472:Commit e3276ae029 pushed by root
trunk
2025-07-17 10:15:40 +08:00
0s
KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)
#471:Commit 05f012c7f1 pushed by root
4.1
2025-07-18 02:35:40 +08:00
0s
Cherrypick "MINOR : Handle error for client telemetry push (#19881)" (#20176)
#470:Commit 70c51641fb pushed by root
4.0
2025-07-18 05:25:27 +08:00
0s
MINOR: Add ShareFetch quota session verification test (#20164)
#469:Commit 65a9337739 pushed by root
trunk
2025-07-17 02:05:53 +08:00
0s
MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR (#20174)
#468:Commit 98cb8df7a5 pushed by root
4.1
2025-07-17 02:05:51 +08:00
0s
MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) (#20131)
#464:Commit daece61a50 pushed by root
trunk
2025-07-16 17:55:54 +08:00
0s
KAFKA-19459: List internal topics for the user (#20157)
#463:Commit 7ea32a0e93 pushed by root
trunk
2025-07-16 01:35:36 +08:00
0s
KAFKA-19504: Remove unused metrics reporter initialization in KafkaAdminClient (#20166)
#462:Commit dd82542493 pushed by root
trunk
2025-07-15 17:25:32 +08:00
0s
KAFKA-19504: Remove unused metrics reporter initialization in KafkaAdminClient (#20166)
#461:Commit f35f94b3e6 pushed by root
4.1
2025-07-16 11:25:27 +08:00
0s
KAFKA-19504: Remove unused metrics reporter initialization in KafkaAdminClient (#20166)
#460:Commit d95857a155 pushed by root
4.0
2025-07-16 11:25:27 +08:00
0s
KAFKA-19452: Fix flaky test LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments (#20121)
#456:Commit a61a37f7dd pushed by root
trunk
2025-07-15 09:16:31 +08:00
0s
KAFKA-19478 [2/N]: Remove task pairs (#20127)
#455:Commit 29cf97b9ad pushed by root
trunk
2025-07-15 01:05:36 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#448:Scheduled
trunk
2025-07-14 05:25:23 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#444:Scheduled
trunk
2025-07-13 00:00:23 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#443:Commit 986322dc36 pushed by root
trunk
2025-07-12 00:00:23 +08:00
0s
KAFKA-19495: Update config for native image (v4.1.0) (#20151)
#442:Commit 793294bd2e pushed by root
4.1
2025-07-13 05:25:23 +08:00
0s
MINOR: Cleanup Connect Module (1/n) (#19869)
#441:Commit 27383970b6 pushed by root
trunk
2025-07-11 23:35:36 +08:00
0s
KAFKA-19485: Added check before sending acknowledgements on initial epoch. (#20135)
#437:Commit 56a3c6dde9 pushed by root
trunk
2025-07-11 07:15:32 +08:00
0s
Merge tag '4.1.0-rc0' into 4.1
#436:Commit d0a308e4f6 pushed by root
4.1
2025-07-11 23:25:28 +08:00
0s
MINOR: fix docker_release example (#19427)
#435:Commit ded7df9707 pushed by root
trunk
2025-07-10 23:05:38 +08:00
0s
MINOR: Throw exceptions if source topic is missing (#20123)
#434:Commit c625b44d8c pushed by root
trunk
2025-07-10 14:55:37 +08:00
0s
KAFKA-19477: Sticky Assignor JMH Benchmark (#20118)
#430:Commit dabde76ebf pushed by root
trunk
2025-07-10 06:45:33 +08:00
0s
KAFKA-19184: Add documentation for upgrading the kraft version (#20071)
#429:Commit b0ff9ba161 pushed by root
4.1
2025-07-10 23:05:37 +08:00
0s
KAFKA-19474 Move WARN log on log truncation below HWM (#20106)
#428:Commit 36b9bb94f1 pushed by root
trunk
2025-07-09 22:35:39 +08:00
0s
KAFKA-19444: Add back JoinGroup v0 & v1 (#20116)
#427:Commit 80b9abebad pushed by root
4.0
2025-07-10 17:25:25 +08:00
0s
KAFKA-18681: Created GetReplicaLogInfo RPCs (#19664)
#426:Commit d86ba7f54a pushed by root
trunk
2025-07-09 14:25:33 +08:00
0s
KAFKA-18288: Fix Streams CLI describe (#20099)
#422:Commit db1c6f31a3 pushed by root
trunk
2025-07-09 06:15:34 +08:00
0s
MINOR: Prevent unnecessary test runs - KAFKA-19042 follow-up (#20122)
#421:Commit dde0b8cd92 pushed by root
trunk
2025-07-08 22:05:33 +08:00
0s
KAFKA-19444: Add back JoinGroup v0 & v1 (#20116)
#420:Commit 487af011ca pushed by root
4.1
2025-07-09 17:25:26 +08:00
0s
MINOR: Fix build warning in Streams (#20098)
#418:Commit a3ed705092 pushed by root
trunk
2025-07-08 13:55:33 +08:00
0s
KAFKA-19397: Ensure consistent metadata usage in produce request and response (#19964)
#415:Commit e6b78ae9e5 pushed by root
4.1
2025-07-08 13:55:32 +08:00
0s
KAFKA-19315 Move ControllerMutationQuotaManager to server module (#19807)
#413:Commit e8ee7fc210 pushed by root
trunk
2025-07-08 05:25:24 +08:00
0s
MINOR: Use <code> block instead of backtick (#20107)
#410:Commit d31885d33c pushed by root
trunk
2025-07-07 05:15:31 +08:00
0s
KAFKA-19221 Propagate IOException on LogSegment#close (#20072)
#408:Commit 8433ac4d31 pushed by root
4.0
2025-07-07 05:25:24 +08:00
0s
KAFKA-19397: Ensure consistent metadata usage in produce request and response (#19964)
#405:Scheduled
#20102/merge
2025-07-07 05:25:23 +08:00
0s
KAFKA-18035: Backport TransactionsTest testBumpTransactionalEpochWithTV2Disabled failed on trunk (#20102)
#404:Commit 45327fd597 pushed by root
4.0
2025-07-06 04:45:30 +08:00
0s
KAFKA-19397: Ensure consistent metadata usage in produce request and response (#19964)
#402:Commit 9df616da76 pushed by root
trunk
2025-07-06 05:25:34 +08:00
0s
KAFKA-19363: Finalize heterogeneous simple share assignor (#20074)
#399:Scheduled
trunk
2025-07-05 04:15:32 +08:00
0s
KAFKA-19363: Finalize heterogeneous simple share assignor (#20074)
#398:Commit 860853dba2 pushed by root
trunk
2025-07-05 00:00:23 +08:00
0s
MINOR: Update the docs for Metrics (#20094)
#396:Commit 4e31e270ba pushed by root
trunk
2025-07-04 20:05:33 +08:00
0s
MINOR: Fix the tests in LogValidatorTest (#20093)
#393:Commit 2e3ddb22ae pushed by root
trunk
2025-07-04 03:45:33 +08:00
0s
KAFKA-19462: Count fetch size when remote fetch (#20088)
#392:Commit eb378da99c pushed by root
trunk
2025-07-03 19:35:34 +08:00
0s
KAFKA-19463: nextFetchOffset does not take ongoing state transition into account (#20080)
#389:Commit 7cb370b786 pushed by root
trunk
2025-07-03 11:25:31 +08:00
0s
KAFKA-19453: Ignore group not found in share group record replay. (#20076)
#387:Commit 28c53ba09a pushed by root
trunk
2025-07-03 03:15:33 +08:00
0s
MINOR: simplify OpenIterator (#20060)
#386:Commit eaa55c420b pushed by root
trunk
2025-07-02 19:05:32 +08:00
0s
MINOR: Remove threadNamePrefix parameter from ReplicaManager and ReplicaFetcherManager (#20069)
#382:Commit ad934d3202 pushed by root
trunk
2025-07-02 10:55:32 +08:00
0s
KAFKA-19152: Add top-level documentation for OAuth flows (#20025)
#381:Commit 3c902bacc0 pushed by root
trunk
2025-07-02 02:45:31 +08:00
0s
MINOR: improve StreamsProducer error handling (#20058)
#380:Commit c8f83592b2 pushed by root
trunk
2025-07-01 18:35:31 +08:00
0s
MINOR: remove unused FlattenedIterator (#20067)
#376:Commit 64aebb5621 pushed by root
trunk
2025-07-01 10:25:33 +08:00
0s
KAFKA-19379: Basic upgrade guide for KIP-1071 EA (#20029)
#375:Commit 53d654ab6e pushed by root
trunk
2025-07-01 02:15:33 +08:00
0s
MINOR: Fix typo in AssignmentsManager (#20059)
#371:Commit 21e97e3c10 pushed by root
trunk
2025-06-30 18:05:35 +08:00
0s
KAFKA-10357: Add new Kafka Streams exception classes (#19988)
#370:Commit a5a54dc32b pushed by root
trunk
2025-06-30 01:45:32 +08:00
0s
KAFKA-19420 Don't export SocketServer from ClusterInstance (#20002)
#366:Scheduled
trunk
2025-06-29 09:25:31 +08:00
0s
KAFKA-19420 Don't export SocketServer from ClusterInstance (#20002)
#362:Commit 05b6e81688 pushed by root
trunk
2025-06-29 00:00:23 +08:00
0s
MINOR: Cleanup hasMemberSubscriptionChanged (#20047)
#361:Scheduled
trunk
2025-06-28 00:45:33 +08:00
0s
MINOR: Cleanup hasMemberSubscriptionChanged (#20047)
#360:Commit 202e216a60 pushed by root
trunk
2025-06-28 00:00:23 +08:00
0s
MINOR: Improve ProcessorContext JavaDocs (#20042)
#359:Commit 53faeb85ef pushed by root
trunk
2025-06-27 16:35:33 +08:00
0s
MINOR: Improve ProcessorContext JavaDocs (#20042)
#358:Commit 4ce6f5cb92 pushed by root
4.0
2025-06-28 11:25:25 +08:00
0s
KAFKA-19436: Restrict cache update for ongoing batch/offset state (#20041)
#354:Commit 96ef1c520a pushed by root
trunk
2025-06-27 08:25:36 +08:00
0s
MINOR: Cleanup ShareFetchAcknowledgeRequestTest (#19852)
#353:Commit 56aeaa4c44 pushed by root
trunk
2025-06-27 00:15:34 +08:00
0s
KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager (#19742)
#352:Commit 7aaba96cc1 pushed by root
trunk
2025-06-26 16:05:33 +08:00
0s
MINOR: Fix response for consumer group describe with empty group id (#20030) (#20036)
#351:Commit 6351bc05aa pushed by root
4.0
2025-06-27 08:25:34 +08:00
0s
MINOR: Reject requests using unsupported features in KIP-1071 (#20031)
#347:Commit 23ddb1d8ac pushed by root
trunk
2025-06-26 07:55:32 +08:00
0s
KAFKA-18656 Backport KAFKA-18597 to 4.0 (#20026)
#346:Commit 15ec053665 pushed by root
4.0
2025-06-26 07:55:31 +08:00
0s
KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically (#20022)
#345:Commit 4387132926 pushed by root
trunk
2025-06-25 23:45:34 +08:00
0s
KAFKA-19383: Handle the deleted topics when applying ClearElrRecord (#20034)
#344:Commit 46e843da9f pushed by root
4.0
2025-06-25 23:45:33 +08:00
0s
KAFKA-19294: Fix BrokerLifecycleManager RPC timeouts (#19745)
#343:Commit 6b2013a001 pushed by root
trunk
2025-06-25 15:35:35 +08:00
0s
KAFKA-19411: Fix deleteAcls bug which allows more deletions than max records per user op (#19974)
#342:Commit 52a5b88512 pushed by root
4.0
2025-06-25 15:35:34 +08:00
0s
KAFKA-19244: Fix flaky streams offsets reset integration test (#20027)
#338:Commit d61b162b13 pushed by root
trunk
2025-06-25 07:25:37 +08:00
0s
MINOR: Change exceptions for few error codes in SharePartition. (#20020)
#337:Commit 3d4407ff9d pushed by root
trunk
2025-06-24 23:15:32 +08:00
0s
KAFKA-19367: Follow up bug fix (#19991)
#336:Commit c8b8adf3c1 pushed by root
4.0
2025-06-25 07:25:35 +08:00
0s
MINOR: Change snapshot epoch type to int32 in schema. (#20016)
#332:Commit cb809e2574 pushed by root
trunk
2025-06-24 06:55:35 +08:00
0s
MINOR: Add retention prop to share group state topic. (#20013)
#331:Commit 56a6ba2d2e pushed by root
trunk
2025-06-23 22:45:32 +08:00
0s
MINOR: Restore original behavior of GroupAuthorizerIntegrationTest (#19968)
#327:Commit 583acb60d6 pushed by root
trunk
2025-06-23 06:25:32 +08:00
0s
MINOR: Cleanup Core Module- Scala Modules (3/n) (#19804)
#325:Commit 992eaafb62 pushed by root
trunk
2025-06-22 22:15:33 +08:00
0s
MINOR: changed the test testShareFetchRequestSuccessfulSharingBetweenMultipleConsumers to remove ambiguity (#19997)
#322:Scheduled
trunk
2025-06-22 05:55:31 +08:00
0s
MINOR: changed the test testShareFetchRequestSuccessfulSharingBetweenMultipleConsumers to remove ambiguity (#19997)
#321:Commit 7c77519f59 pushed by root
trunk
2025-06-22 00:00:23 +08:00
0s
KAFKA-19402: Typo in EventAccumulator.java (#19951)
#319:Commit d442c31e92 pushed by root
trunk
2025-06-21 21:45:32 +08:00
0s
MINOR: Reduce logging in persister. (#19998)
#316:Scheduled
trunk
2025-06-21 05:25:34 +08:00
0s
MINOR: Reduce logging in persister. (#19998)
#315:Commit d5e2ecae95 pushed by root
trunk
2025-06-21 00:00:23 +08:00
0s
MINOR: fix MetadataRequest and MetadataResponse doc (#19963)
#314:Commit d59d39a229 pushed by root
trunk
2025-06-20 21:15:33 +08:00
0s
KAFKA-19140 ConnectAssignor#performAssignment parameter can be replace to ConnectProtocolCompatibility (#19476)
#312:Commit 15ad3016b7 pushed by root
trunk
2025-06-20 13:05:33 +08:00
0s
MINOR : Fix possible flake in ShareConsumerTest:testConsumerCloseInGroupSequential (#19986)
#309:Commit 55297967a9 pushed by root
trunk
2025-06-20 04:55:32 +08:00
0s
KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription (#19983)
#308:Commit ce996b34e9 pushed by root
trunk
2025-06-19 20:46:43 +08:00
0s
KAFKA-18627 Deprecated "org.apache.kafka.disallowed.login.modules" (#18683)
#306:Commit b8fc96272e pushed by root
trunk
2025-06-19 12:36:45 +08:00
0s
KAFKA-19413: Extended AuthorizerIntegrationTest to cover StreamsGroupDescribe (#19981)
#303:Commit 2a06335569 pushed by root
trunk
2025-06-19 04:26:44 +08:00
0s
KAFKA-19367: Follow up bug fix (#19976)
#302:Commit ba7b5c9b32 pushed by root
trunk
2025-06-18 20:16:45 +08:00
0s
KAFKA-14145; Faster KRaft HWM replication (#19800)
#300:Commit 742b327025 pushed by root
trunk
2025-06-18 12:06:46 +08:00
0s
MINOR: in min.insync.replicas config doc, explicitly state that all ISR must ack when acks=all (#19973)
#297:Commit 6f946d5026 pushed by root
trunk
2025-06-18 03:56:47 +08:00
0s
KAFKA-18486 Remove ReplicaManager#becomeLeaderOrFollower from testFencedErrorCausedByBecomeLeader and other similar methods (#19966)
#294:Commit fd70290633 pushed by root
trunk
2025-06-17 11:36:44 +08:00
0s
HOTFIX: Correcting build after cherry-pick (#19969)
#292:Commit 26e5a53906 pushed by root
4.0
2025-06-17 23:26:44 +08:00
0s
KAFKA-18486 Migrate ReplicaManagerTest#testTransactionAddPartitionRetry and other similar methods to use applyDelta (#19965)
#291:Commit 86419e9b8a pushed by root
trunk
2025-06-17 03:26:44 +08:00
0s
MINOR: Fix typo to actually use rocksdb setOptimizeFiltersForHits (#19837)
#287:Commit a83bfda39b pushed by root
trunk
2025-06-16 11:06:44 +08:00
0s
Cherry Pick KAFKA-19367 to 4.0 (#19958)
#286:Commit c6b44b5d66 pushed by root
4.0
2025-06-16 11:26:34 +08:00
0s
KAFKA-18486: Migrate ReplicaManagerTest to use applyDelta (#19954)
#282:Scheduled
trunk
2025-06-16 02:56:44 +08:00
0s
KAFKA-18486: Migrate ReplicaManagerTest to use applyDelta (#19954)
#281:Commit 081deaa1a9 pushed by root
trunk
2025-06-15 00:00:34 +08:00
0s
MINOR: rename exception `e` to `swallow` where appropriate (#19948)
#277:Commit 99e1e684ef pushed by root
trunk
2025-06-14 18:16:43 +08:00
0s
KAFKA-18486 Migrate ReplicaManagerTest RemoteFetchExpiresPerSecMetric and RemoteLogReaderMetrics with applyDelta (#19960)
#276:Scheduled
trunk
2025-06-14 01:56:44 +08:00
0s
KAFKA-18486 Migrate ReplicaManagerTest RemoteFetchExpiresPerSecMetric and RemoteLogReaderMetrics with applyDelta (#19960)
#275:Commit 94807bcd15 pushed by root
trunk
2025-06-14 00:00:35 +08:00
0s
MINOR: Fixing client telemetry validate request (#19959)
#274:Commit 2572c7ff9d pushed by root
trunk
2025-06-13 17:46:47 +08:00
0s
MINOR: Fixing client telemetry validate request (#19959)
#273:Commit 254c1fa519 pushed by root
4.0
2025-06-14 11:26:39 +08:00
0s
KAFKA-19367: Fix InitProducerId with TV2 double-increments epoch if ongoing transaction is aborted (#19910)
#269:Commit 0b2e410d61 pushed by root
trunk
2025-06-13 09:36:45 +08:00
0s
KAFKA-18486 Migrate testPartitionMetadataFile to use applyDelta in place of deprecated becomeLeaderOrFollower (#19947)
#268:Commit 2a7457f2dd pushed by root
trunk
2025-06-13 01:26:45 +08:00
0s
KAFKA-18486 Update testClearPurgatoryOnBecomingFollower etc with KRaft mechanism in ReplicaManagerTest (#19924)
#264:Commit 7c715c02c0 pushed by root
trunk
2025-06-12 17:16:46 +08:00
0s
MINOR: Bump trunk to 4.2.0-SNAPSHOT (#19944)
#263:Commit b704280a0a pushed by root
trunk
2025-06-12 00:56:46 +08:00
0s
Bump the commons-beanutils for CVE-2025-48734. Since `commons-validator`
#262:Commit 00a1b1e8ce pushed by root
4.0
2025-06-12 17:26:39 +08:00
0s
MINOR: Update opentelemetry-proto dependency (#19945)
#261:Commit 7dd07eb9ba pushed by root
trunk
2025-06-11 16:46:46 +08:00
0s
MINOR: Remove unused code from storage classes (#19853)
#257:Commit f69379cf6b pushed by root
trunk
2025-06-11 08:36:45 +08:00
0s
KAFKA-19382:Upgrade junit from 5.10 to 5.13 (#19919)
#256:Commit 465b01cd2c pushed by root
trunk
2025-06-11 00:26:46 +08:00
0s
MINOR: ELR release note for 4.1 (#19909)
#255:Commit b420e4092e pushed by root
trunk
2025-06-10 16:16:45 +08:00
0s
KAFKA-19271: allow intercepting internal method call (#19832)
#251:Commit 0adc6fa3e1 pushed by root
trunk
2025-06-10 08:06:43 +08:00
0s
MINOR: Use `pollUntilTrue` instead of `waitForCondition` (#19911)
#250:Commit d6861f3f15 pushed by root
trunk
2025-06-09 23:56:44 +08:00
0s
KAFKA-19334 MetadataShell execution unintentionally deletes lock file (#19817)
#249:Commit 1cc14f6343 pushed by root
4.0
2025-06-10 17:26:34 +08:00
0s
MINOR: Follow up KAFKA-19080 MetadataLogConfig (#19842)
#248:Commit df73133f3b pushed by root
trunk
2025-06-09 15:46:44 +08:00
0s
KAFKA-19042 Move PlaintextConsumerSubscriptionTest to client-integration-tests module (#19827)
#244:Commit 8fd0d33670 pushed by root
trunk
2025-06-09 07:36:41 +08:00
0s
KAFKA-19295: Remove AsyncKafkaConsumer event ID generation (#19915)
#240:Scheduled
trunk
2025-06-08 07:06:46 +08:00
0s
KAFKA-19295: Remove AsyncKafkaConsumer event ID generation (#19915)
#239:Commit 861eeb859d pushed by root
trunk
2025-06-08 00:00:34 +08:00
0s
MINOR: Rename ambiguous method name (#19875)
#238:Commit c4a769bc8b pushed by root
trunk
2025-06-07 22:56:44 +08:00
0s
KAFKA-19369: Add group.share.assignors config and integration test (#19900)
#234:Scheduled
trunk
2025-06-07 06:36:44 +08:00
0s
KAFKA-19369: Add group.share.assignors config and integration test (#19900)
#233:Commit 844b0e651b pushed by root
trunk
2025-06-07 00:00:34 +08:00
0s