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)
#638:Scheduled
trunk
2025-10-08 06:00:20 +08:00
0s
MINOR: Adjust the timing for creating connect config (#20612)
#632:Scheduled
trunk
2025-10-07 06:55:01 +08:00
0s
MINOR: Enable streams rebalance protocol in EosIntegrationTest (#20592)
#627:Scheduled
trunk
2025-10-06 22:44:56 +08:00
0s
MINOR: Fix a minor copy&paste typo in comments (#20634)
#623:Scheduled
trunk
2025-10-05 22:14:54 +08:00
0s
KAFKA-18185: remove internal.leave.group.on.close config (#19400)
#616:Scheduled
trunk
2025-10-04 13:34:52 +08:00
0s
KAFKA-19467; Add a metric for controller thread idleness (#20422)
#610:Scheduled
trunk
2025-10-03 13:04:52 +08:00
0s
MINOR: Typo in ListShareGroupOffsetsResults javadoc (#20623)
#604:Scheduled
trunk
2025-10-02 20:44:54 +08:00
0s
KAFKA-19692 improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions (#20555)
#598:Scheduled
trunk
2025-10-02 04:24:57 +08:00
0s
KAFKA-15873: Filter topics before sorting (#19304)
#593:Scheduled
trunk
2025-10-01 03:54:57 +08:00
0s
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
#583:Scheduled
trunk
2025-09-29 11:11:23 +08:00
0s
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
#581:Scheduled
trunk
2025-09-29 10:04:28 +08:00
0s
KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement (#20286)
#577:Scheduled
#18935/merge
2025-09-29 10:04:20 +08:00
0s
KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
#572:Scheduled
#20274/merge
2025-08-03 10:30:15 +08:00
0s
MINOR: add test for `kafka-consumer-groups.sh` should not fail when partition offline (#20235)
#565:Scheduled
trunk
2025-08-01 09:38:42 +08:00
0s
KAFKA-19489; Extra validation when formatting a node (#20136)
#559:Scheduled
trunk
2025-07-31 07:28:12 +08:00
0s
KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline (#20218)
#554:Scheduled
trunk
2025-07-30 06:50:18 +08:00
0s
KAFKA-19551: Remove the handling of FatalExitError in RemoteStorageThreadPool (#20245)
#547:Scheduled
trunk
2025-07-29 06:20:16 +08:00
0s
KAFKA-19471: Enable acknowledgement for a record which could not be deserialized (#20148)
#543:Scheduled
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)
#539:Scheduled
trunk
2025-07-28 05:50:21 +08:00
0s
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
#534:Scheduled
trunk
2025-07-27 06:00:07 +08:00
0s
KAFKA-19523: Gracefully handle error while building remoteLogAuxState (#20201)
#523:Scheduled
trunk
2025-07-24 09:59:26 +08:00
0s
KAFKA-19503: Deprecate MX4j support (#20208)
#515:Scheduled
trunk
2025-07-23 07:34:13 +08:00
0s
MINOR: Change log level for cold snapshot log. (#20209)
#511:Scheduled
trunk
2025-07-22 20:55:39 +08:00
0s
MINOR: Move ClientQuotasRequestTest to server module (#20053)
#504:Scheduled
trunk
2025-07-21 12:15:55 +08:00
0s
MINOR: add a test for Protocol (#20169)
#498:Scheduled
trunk
2025-07-20 19:55:35 +08:00
0s
MINOR: Correct RemoteLogManager.getLeaderEpochEntries comment (#20181)
#489:Scheduled
trunk
2025-07-19 11:15:42 +08:00
0s
MINOR: Migrate CoordinatorLoaderImpl from Scala to Java (#20089)
#482:Scheduled
trunk
2025-07-18 10:45:38 +08:00
0s
KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)
#475:Scheduled
trunk
2025-07-17 10:15:40 +08:00
0s
MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) (#20131)
#467:Scheduled
trunk
2025-07-16 17:55:54 +08:00
0s
KAFKA-19452: Fix flaky test LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments (#20121)
#459:Scheduled
trunk
2025-07-15 09:16:32 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#454:Scheduled
#19082/merge
2025-07-15 11:25:24 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#451:Scheduled
trunk
2025-07-14 11:25:23 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#447:Scheduled
trunk
2025-07-13 06:00:23 +08:00
0s
KAFKA-19485: Added check before sending acknowledgements on initial epoch. (#20135)
#440:Scheduled
trunk
2025-07-11 07:15:32 +08:00
0s
KAFKA-19477: Sticky Assignor JMH Benchmark (#20118)
#433:Scheduled
trunk
2025-07-10 06:45:33 +08:00
0s
KAFKA-18288: Fix Streams CLI describe (#20099)
#425:Scheduled
trunk
2025-07-09 06:15:34 +08:00
0s
MINOR: Fix build warning in Streams (#20098)
#419:Scheduled
trunk
2025-07-08 13:55:33 +08:00
0s
KAFKA-19315 Move ControllerMutationQuotaManager to server module (#19807)
#414:Scheduled
trunk
2025-07-08 05:45:34 +08:00
0s
KAFKA-19397: Ensure consistent metadata usage in produce request and response (#19964)
#409:Scheduled
#20072/merge
2025-07-07 11:25:23 +08:00
0s
KAFKA-19397: Ensure consistent metadata usage in produce request and response (#19964)
#403:Scheduled
trunk
2025-07-06 11:25:23 +08:00
0s
MINOR: Update the docs for Metrics (#20094)
#397:Scheduled
trunk
2025-07-04 20:05:33 +08:00
0s
KAFKA-19463: nextFetchOffset does not take ongoing state transition into account (#20080)
#391:Scheduled
trunk
2025-07-03 11:25:31 +08:00
0s
MINOR: Remove threadNamePrefix parameter from ReplicaManager and ReplicaFetcherManager (#20069)
#385:Scheduled
trunk
2025-07-02 10:55:33 +08:00
0s
MINOR: remove unused FlattenedIterator (#20067)
#379:Scheduled
trunk
2025-07-01 10:25:33 +08:00
0s
MINOR: Fix typo in AssignmentsManager (#20059)
#374:Scheduled
trunk
2025-06-30 18:05:35 +08:00
0s
KAFKA-19420 Don't export SocketServer from ClusterInstance (#20002)
#369:Scheduled
#19265/merge
2025-06-30 11:25:23 +08:00
0s
KAFKA-19420 Don't export SocketServer from ClusterInstance (#20002)
#365:Scheduled
trunk
2025-06-29 09:25:31 +08:00
0s
KAFKA-19436: Restrict cache update for ongoing batch/offset state (#20041)
#357:Scheduled
trunk
2025-06-27 08:25:36 +08:00
0s
MINOR: Reject requests using unsupported features in KIP-1071 (#20031)
#350:Scheduled
trunk
2025-06-26 07:55:32 +08:00
0s
KAFKA-19244: Fix flaky streams offsets reset integration test (#20027)
#341:Scheduled
trunk
2025-06-25 07:25:37 +08:00
0s
MINOR: Change snapshot epoch type to int32 in schema. (#20016)
#335:Scheduled
trunk
2025-06-24 06:55:35 +08:00
0s
MINOR: Restore original behavior of GroupAuthorizerIntegrationTest (#19968)
#330:Scheduled
trunk
2025-06-23 06:25:32 +08:00
0s
MINOR: changed the test testShareFetchRequestSuccessfulSharingBetweenMultipleConsumers to remove ambiguity (#19997)
#326:Scheduled
trunk
2025-06-22 22:15:33 +08:00
0s
KAFKA-19402: Typo in EventAccumulator.java (#19951)
#320:Scheduled
trunk
2025-06-21 21:45:32 +08:00
0s
KAFKA-19140 ConnectAssignor#performAssignment parameter can be replace to ConnectProtocolCompatibility (#19476)
#313:Scheduled
trunk
2025-06-20 13:05:33 +08:00
0s
KAFKA-18627 Deprecated "org.apache.kafka.disallowed.login.modules" (#18683)
#307:Scheduled
trunk
2025-06-19 12:36:45 +08:00
0s
KAFKA-14145; Faster KRaft HWM replication (#19800)
#301:Scheduled
trunk
2025-06-18 12:06:46 +08:00
0s
KAFKA-18486 Remove ReplicaManager#becomeLeaderOrFollower from testFencedErrorCausedByBecomeLeader and other similar methods (#19966)
#296:Scheduled
trunk
2025-06-17 11:36:44 +08:00
0s
MINOR: Fix typo to actually use rocksdb setOptimizeFiltersForHits (#19837)
#290:Scheduled
trunk
2025-06-16 11:06:44 +08:00
0s
KAFKA-18486: Migrate ReplicaManagerTest to use applyDelta (#19954)
#285:Scheduled
trunk
2025-06-16 02:56:44 +08:00
0s
MINOR: rename exception `e` to `swallow` where appropriate (#19948)
#280:Scheduled
trunk
2025-06-14 18:16:43 +08:00
0s
KAFKA-19367: Fix InitProducerId with TV2 double-increments epoch if ongoing transaction is aborted (#19910)
#272:Scheduled
trunk
2025-06-13 09:36:45 +08:00
0s
KAFKA-18486 Update testClearPurgatoryOnBecomingFollower etc with KRaft mechanism in ReplicaManagerTest (#19924)
#267:Scheduled
trunk
2025-06-12 17:16:46 +08:00
0s
MINOR: Remove unused code from storage classes (#19853)
#260:Scheduled
trunk
2025-06-11 08:36:45 +08:00
0s
KAFKA-19271: allow intercepting internal method call (#19832)
#254:Scheduled
trunk
2025-06-10 08:06:43 +08:00
0s
KAFKA-19042 Move PlaintextConsumerSubscriptionTest to client-integration-tests module (#19827)
#247:Scheduled
trunk
2025-06-09 07:36:41 +08:00
0s
KAFKA-19295: Remove AsyncKafkaConsumer event ID generation (#19915)
#243:Scheduled
trunk
2025-06-08 07:06:46 +08:00
0s
KAFKA-19369: Add group.share.assignors config and integration test (#19900)
#237:Scheduled
trunk
2025-06-07 06:36:44 +08:00
0s
MINOR: clean KafkaConsumer tests (#19669)
#231:Scheduled
trunk
2025-06-06 06:06:44 +08:00
0s
KAFKA-18042: Reject the produce request with lower producer epoch early (KIP-890) (#19844)
#226:Scheduled
trunk
2025-06-05 13:46:42 +08:00
0s
KAFKA-19176: Update Transactional producer to translate retriable into abortable exceptions (#19522)
#220:Scheduled
trunk
2025-06-04 13:16:45 +08:00
0s
KAFKA-19358: Updated share_consumer_test.py tests to use set_group_offset_reset_strategy (#19878)
#215:Scheduled
trunk
2025-06-03 20:56:44 +08:00
0s
KAFKA-19355 Remove interBrokerListenerName from ClusterControlManager (#19866)
#210:Scheduled
trunk
2025-06-02 20:26:50 +08:00
0s
KAFKA-19284 Add documentation to clarify the behavior of null values for all partitionsToOffsetAndMetadata methods. (#19728)
#206:Scheduled
trunk
2025-06-02 04:06:44 +08:00
0s
KAFKA-19042 Move GroupAuthorizerIntegrationTest to clients-integration-tests module (#19685)
#201:Scheduled
trunk
2025-06-01 03:36:41 +08:00
0s
KAFKA-19042 move ConsumerWithLegacyMessageFormatIntegrationTest to clients-integration-tests module (#19810)
#195:Scheduled
trunk
2025-05-30 18:56:43 +08:00
0s
KAFKA-19347 Don't update timeline data structures in createAcls (#19840)
#189:Scheduled
trunk
2025-05-29 10:20:27 +08:00
0s
KAFKA-19154; Offset Fetch API should return INVALID_OFFSET if requested topic id does not match persisted one (#19744)
#182:Scheduled
trunk
2025-05-28 09:50:28 +08:00
0s
KAFKA-19322 Remove the DelayedOperation constructor that accepts an external lock (#19798)
#175:Scheduled
trunk
2025-05-27 09:20:23 +08:00
0s
KAFKA-19080 The constraint on segment.ms is not enforced at topic level (#19371)
#169:Scheduled
trunk
2025-05-26 08:50:24 +08:00
0s
KAFKA-19313 Replace LogOffsetMetadata#UNIFIED_LOG_UNKNOWN_OFFSET by UnifiedLog.UNKNOWN_OFFSET (#19767)
#164:Scheduled
trunk
2025-05-25 16:30:30 +08:00
0s
KAFKA-19260 Move LoggingController to server module (#19687)
#158:Scheduled
trunk
2025-05-24 07:50:22 +08:00
0s
KAFKA-18904: Add Admin#listConfigResources [2/N] (#19743)
#152:Scheduled
trunk
2025-05-23 07:20:36 +08:00
0s
KAFKA-4650: Add unit tests for GraphNode class (#18951)
#147:Scheduled
trunk
2025-05-22 15:00:24 +08:00
0s
MINOR: Cleanup Share Coordinator (#19770)
#140:Scheduled
trunk
2025-05-21 06:20:25 +08:00
0s
KAFKA-19302 Move ReplicaState and Replica to server module (#19755)
#135:Scheduled
trunk
2025-05-20 14:00:24 +08:00
0s
MINOR: Refactor shared-group request handle methods to return CompletableFuture for consistent error handling (#19724)
#130:Scheduled
trunk
2025-05-19 21:40:27 +08:00
0s
KAFKA-19202: Enable KIP-1071 in streams_eos_test (#19700)
#126:Scheduled
trunk
2025-05-19 05:20:34 +08:00
0s
MINOR: Move logDirs config out of KafkaConfig (#19579)
#120:Scheduled
trunk
2025-05-17 12:30:59 +08:00
0s
MINOR: Improvements for Persister APIs with respect to share group protocol enablement (#19719)
#111:Scheduled
trunk
2025-05-16 12:00:28 +08:00
0s
KAFKA-18666: Controller-side monitoring for broker shutdown and startup (#19586)
#104:Scheduled
trunk
2025-05-15 11:30:31 +08:00
0s
KAFKA-18847: Refactor OAuth layer to improve reusability 1/N (#19622)
#97:Scheduled
trunk
2025-05-14 11:00:25 +08:00
0s
MINOR: Add deprecation of listConsumerGroups to upgrade.html (#19684)
#90:Scheduled
trunk
2025-05-13 10:30:28 +08:00
0s
KAFKA-18695 Remove quorum=kraft and kip932 from all integration tests (#19633)
#82:Scheduled
trunk
2025-05-12 10:00:44 +08:00
0s
KAFKA-19068 Eliminate the duplicate type check in creating ControlRecord (#19346)
#78:Scheduled
trunk
2025-05-12 01:50:24 +08:00
0s
KAFKA-19229: Ignore background errors while closing share consumers. (Fix flaky test) (#19647)
#71:Scheduled
trunk
2025-05-10 09:00:25 +08:00
0s
KAFKA-19182 Move SchedulerTest to server module (#19608)
#64:Scheduled
trunk
2025-05-09 08:30:25 +08:00
0s
MINOR; Add `--standalone --ignore-formatted` formatter test (#19643)
#57:Scheduled
trunk
2025-05-08 08:00:25 +08:00
0s
KAFKA-19218: Add missing leader epoch to share group state summary response (#19602)
#52:Scheduled
trunk
2025-05-07 07:30:26 +08:00
0s
KAFKA-19232: Handle Share session limit reached exception in clients. (#19619)
#46:Scheduled
#19632/merge
2025-05-07 11:40:15 +08:00
0s
MINOR: replace .stream().forEach() with .forEach() (#19626)
#42:Scheduled
trunk
2025-05-05 06:30:26 +08:00
0s
MINOR: Change info log to debug for scheduled timer tasks. (#19624)
#36:Scheduled
trunk
2025-05-04 06:00:25 +08:00
0s
KAFKA-19204: Allow persister retry of initializing topics. (#19603)
#30:Scheduled
trunk
2025-05-03 13:40:23 +08:00
0s
KAFKA-19146 Merge OffsetAndEpoch from raft to server-common (#19475)
#23:Scheduled
trunk
2025-05-02 13:10:23 +08:00
0s
MINOR: Improve docs for client group configs (#19605)
#17:Scheduled
trunk
2025-05-01 12:40:23 +08:00
0s
KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) (#19470)
#11:Scheduled
trunk
2025-04-30 12:10:25 +08:00
0s
MINOR: Remove unused erroneous code from test (#19585)
#6:Scheduled
trunk
2025-04-29 19:50:22 +08:00
0s