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)
#636:Scheduled
trunk
2025-10-08 03:00:20 +08:00
0s
MINOR: Adjust the timing for creating connect config (#20612)
#630:Scheduled
trunk
2025-10-07 06:55:01 +08:00
0s
MINOR: Enable streams rebalance protocol in EosIntegrationTest (#20592)
#625:Scheduled
trunk
2025-10-06 22:44:56 +08:00
0s
KAFKA-19748: fix metrics leak in Kafka Streams (#20633)
#620:Scheduled
trunk
2025-10-05 05:54:52 +08:00
0s
KAFKA-19744: Move restore time calculation to ChangelogMetadata (#20613)
#613:Scheduled
trunk
2025-10-04 05:24:59 +08:00
0s
KAFKA-9825 Kafka protocol BNF format should have some way to display tagged fields (#20536)
#606:Scheduled
trunk
2025-10-03 04:55:01 +08:00
0s
KAFKA-19692 improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions (#20555)
#599:Scheduled
#20566/merge
2025-10-03 04:04:24 +08:00
4s
KAFKA-15873: Filter topics before sorting (#19304)
#594:Scheduled
#20243/merge
2025-10-02 04:04:25 +08:00
4s
KAFKA-19739 Upgrade commons-validator to 1.10.0 (#20601)
#590:Scheduled
trunk
2025-09-30 03:25:04 +08:00
0s
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
#582:Scheduled
trunk
2025-09-29 11:11:23 +08:00
0s
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
#579:Scheduled
trunk
2025-09-29 10:04:31 +08:00
3s
KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement (#20286)
#575:Scheduled
#18935/merge
2025-08-04 04:34:34 +08:00
1m1s
KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
#570:Scheduled
#20274/merge
2025-08-03 04:33:40 +08:00
12s
MINOR: add test for `kafka-consumer-groups.sh` should not fail when partition offline (#20235)
#563:Scheduled
trunk
2025-08-01 09:38:44 +08:00
1s
KAFKA-19489; Extra validation when formatting a node (#20136)
#557:Scheduled
trunk
2025-07-31 07:28:28 +08:00
12s
KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline (#20218)
#552:Scheduled
trunk
2025-07-30 06:50:18 +08:00
0s
KAFKA-19551: Remove the handling of FatalExitError in RemoteStorageThreadPool (#20245)
#545:Scheduled
trunk
2025-07-29 06:20:17 +08:00
1s
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
#540: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)
#537:Scheduled
trunk
2025-07-28 03:00:07 +08:00
0s
MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap (#20205)
#531:Scheduled
#20008/merge
2025-07-27 04:30:32 +08:00
20s
MINOR: typo in javadoc (#20113)
#527:Scheduled
trunk
2025-07-26 04:30:12 +08:00
4s
KAFKA-19523: Gracefully handle error while building remoteLogAuxState (#20201)
#521:Scheduled
trunk
2025-07-24 09:59:26 +08:00
0s
KAFKA-19503: Deprecate MX4j support (#20208)
#513:Scheduled
trunk
2025-07-23 07:34:13 +08:00
0s
KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N) (#20207)
#508:Scheduled
trunk
2025-07-22 04:35:37 +08:00
0s
KAFKA-19522: avoid electing fenced lastKnownLeader (#20200)
#501:Scheduled
trunk
2025-07-21 04:05:38 +08:00
0s
MINOR: Remove unnecessary dependencies from coordinator-common (follow up to pr#20089) (#20194)
#495:Scheduled
trunk
2025-07-20 03:36:01 +08:00
0s
KAFKA-19509: Improve error message when release version is wrong (#20185)
#486:Scheduled
trunk
2025-07-19 03:05:34 +08:00
0s
MINOR: Migrate CoordinatorLoaderImpl from Scala to Java (#20089)
#480:Scheduled
trunk
2025-07-18 10:45:38 +08:00
0s
KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)
#473:Scheduled
trunk
2025-07-17 10:15:40 +08:00
0s
MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) (#20131)
#465:Scheduled
trunk
2025-07-16 17:55:54 +08:00
0s
KAFKA-19452: Fix flaky test LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments (#20121)
#457:Scheduled
trunk
2025-07-15 09:16:32 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#452:Scheduled
#19082/merge
2025-07-15 05:25:24 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#449:Scheduled
trunk
2025-07-14 05:25:26 +08:00
2s
MINOR: Moving the rollback out of lock in share partition (#20153)
#445:Scheduled
trunk
2025-07-13 03:00:23 +08:00
0s
KAFKA-19485: Added check before sending acknowledgements on initial epoch. (#20135)
#438:Scheduled
trunk
2025-07-11 07:15:32 +08:00
0s
KAFKA-19477: Sticky Assignor JMH Benchmark (#20118)
#431:Scheduled
trunk
2025-07-10 06:45:34 +08:00
1s
KAFKA-18288: Fix Streams CLI describe (#20099)
#423:Scheduled
trunk
2025-07-09 06:15:34 +08:00
0s
KAFKA-19315 Move ControllerMutationQuotaManager to server module (#19807)
#416:Scheduled
#20112/merge
2025-07-09 05:25:27 +08:00
3s
MINOR: Use <code> block instead of backtick (#20107)
#411:Scheduled
trunk
2025-07-07 05:15:31 +08:00
0s
KAFKA-19397: Ensure consistent metadata usage in produce request and response (#19964)
#406:Scheduled
#20102/merge
2025-07-07 05:25:24 +08:00
0s
KAFKA-19363: Finalize heterogeneous simple share assignor (#20074)
#400:Scheduled
trunk
2025-07-05 04:15:32 +08:00
0s
MINOR: Fix the tests in LogValidatorTest (#20093)
#394:Scheduled
trunk
2025-07-04 03:45:33 +08:00
0s
KAFKA-19453: Ignore group not found in share group record replay. (#20076)
#388:Scheduled
trunk
2025-07-03 03:15:33 +08:00
0s
MINOR: Remove threadNamePrefix parameter from ReplicaManager and ReplicaFetcherManager (#20069)
#383:Scheduled
trunk
2025-07-02 10:55:33 +08:00
0s
MINOR: remove unused FlattenedIterator (#20067)
#377:Scheduled
trunk
2025-07-01 10:25:33 +08:00
0s
MINOR: Fix typo in AssignmentsManager (#20059)
#372:Scheduled
trunk
2025-06-30 18:05:35 +08:00
0s
KAFKA-19420 Don't export SocketServer from ClusterInstance (#20002)
#367:Scheduled
#19265/merge
2025-06-30 05:25:35 +08:00
5s
KAFKA-19420 Don't export SocketServer from ClusterInstance (#20002)
#363:Scheduled
trunk
2025-06-29 05:25:39 +08:00
2s
KAFKA-19436: Restrict cache update for ongoing batch/offset state (#20041)
#355:Scheduled
trunk
2025-06-27 08:25:36 +08:00
0s
MINOR: Reject requests using unsupported features in KIP-1071 (#20031)
#348:Scheduled
trunk
2025-06-26 07:55:32 +08:00
0s
KAFKA-19244: Fix flaky streams offsets reset integration test (#20027)
#339:Scheduled
trunk
2025-06-25 07:25:37 +08:00
0s
MINOR: Change snapshot epoch type to int32 in schema. (#20016)
#333:Scheduled
trunk
2025-06-24 06:55:35 +08:00
0s
MINOR: Restore original behavior of GroupAuthorizerIntegrationTest (#19968)
#328:Scheduled
trunk
2025-06-23 06:25:32 +08:00
0s
MINOR: changed the test testShareFetchRequestSuccessfulSharingBetweenMultipleConsumers to remove ambiguity (#19997)
#323:Scheduled
trunk
2025-06-22 22:15:33 +08:00
0s
MINOR: Reduce logging in persister. (#19998)
#317:Scheduled
trunk
2025-06-21 05:25:34 +08:00
0s
MINOR : Fix possible flake in ShareConsumerTest:testConsumerCloseInGroupSequential (#19986)
#310:Scheduled
trunk
2025-06-20 04:55:32 +08:00
0s
KAFKA-19413: Extended AuthorizerIntegrationTest to cover StreamsGroupDescribe (#19981)
#304:Scheduled
trunk
2025-06-19 04:26:44 +08:00
0s
MINOR: in min.insync.replicas config doc, explicitly state that all ISR must ack when acks=all (#19973)
#298:Scheduled
trunk
2025-06-18 03:56:47 +08:00
0s
KAFKA-18486 Migrate ReplicaManagerTest#testTransactionAddPartitionRetry and other similar methods to use applyDelta (#19965)
#293:Scheduled
trunk
2025-06-17 03:26:44 +08:00
0s
MINOR: Fix typo to actually use rocksdb setOptimizeFiltersForHits (#19837)
#288:Scheduled
trunk
2025-06-16 11:06:44 +08:00
0s
KAFKA-18486: Migrate ReplicaManagerTest to use applyDelta (#19954)
#283:Scheduled
trunk
2025-06-16 02:56:44 +08:00
0s
MINOR: rename exception `e` to `swallow` where appropriate (#19948)
#278: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)
#270:Scheduled
trunk
2025-06-13 09:36:45 +08:00
0s
KAFKA-18486 Update testClearPurgatoryOnBecomingFollower etc with KRaft mechanism in ReplicaManagerTest (#19924)
#265:Scheduled
trunk
2025-06-12 17:16:46 +08:00
0s
MINOR: Remove unused code from storage classes (#19853)
#258:Scheduled
trunk
2025-06-11 08:36:45 +08:00
0s
KAFKA-19271: allow intercepting internal method call (#19832)
#252:Scheduled
trunk
2025-06-10 08:06:43 +08:00
0s
KAFKA-19042 Move PlaintextConsumerSubscriptionTest to client-integration-tests module (#19827)
#245:Scheduled
trunk
2025-06-09 07:36:41 +08:00
0s
KAFKA-19295: Remove AsyncKafkaConsumer event ID generation (#19915)
#241:Scheduled
trunk
2025-06-08 07:06:46 +08:00
0s
KAFKA-19369: Add group.share.assignors config and integration test (#19900)
#235:Scheduled
trunk
2025-06-07 06:36:44 +08:00
0s
MINOR: clean KafkaConsumer tests (#19669)
#229:Scheduled
trunk
2025-06-06 06:06:44 +08:00
0s
KAFKA-18573: Add support for OAuth jwt-bearer grant type (#19754)
#223:Scheduled
trunk
2025-06-05 05:36:47 +08:00
0s
KAFKA-19353: Upgrade note and initial docs for KIP-932 (#19863)
#217:Scheduled
trunk
2025-06-04 05:06:44 +08:00
0s
KAFKA-19321: Added share_consumer_performance.py and related system tests (#19836)
#212:Scheduled
trunk
2025-06-03 04:36:44 +08:00
0s
KAFKA-19284 Add documentation to clarify the behavior of null values for all partitionsToOffsetAndMetadata methods. (#19728)
#207:Scheduled
#18738/merge
2025-06-03 05:26:35 +08:00
1s
KAFKA-19042 Move GroupAuthorizerIntegrationTest to clients-integration-tests module (#19685)
#203:Scheduled
trunk
2025-06-01 03:36:41 +08:00
0s
KAFKA-19346: Move LogReadResult to server module (#19846)
#198:Scheduled
trunk
2025-05-31 03:06:45 +08:00
0s
KAFKA-19042 move ConsumerWithLegacyMessageFormatIntegrationTest to clients-integration-tests module (#19810)
#193:Scheduled
trunk
2025-05-30 18:56:43 +08:00
0s
KAFKA-19347 Don't update timeline data structures in createAcls (#19840)
#187: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)
#180:Scheduled
trunk
2025-05-28 09:50:28 +08:00
0s
KAFKA-19322 Remove the DelayedOperation constructor that accepts an external lock (#19798)
#173: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)
#167:Scheduled
trunk
2025-05-26 08:50:24 +08:00
0s
KAFKA-19313 Replace LogOffsetMetadata#UNIFIED_LOG_UNKNOWN_OFFSET by UnifiedLog.UNKNOWN_OFFSET (#19767)
#162:Scheduled
trunk
2025-05-25 16:30:30 +08:00
0s
KAFKA-19260 Move LoggingController to server module (#19687)
#156:Scheduled
trunk
2025-05-24 07:50:23 +08:00
1s
KAFKA-18904: Add Admin#listConfigResources [2/N] (#19743)
#150:Scheduled
trunk
2025-05-23 07:20:36 +08:00
0s
KAFKA-4650: Add unit tests for GraphNode class (#18951)
#145:Scheduled
trunk
2025-05-22 15:00:24 +08:00
0s
MINOR: Cleanup Share Coordinator (#19770)
#138:Scheduled
trunk
2025-05-21 06:20:25 +08:00
0s
KAFKA-17747: [3/N] Get rid of TopicMetadata in SubscribedTopicDescriberImpl (#19611)
#132:Scheduled
trunk
2025-05-20 05:50:34 +08:00
0s
KAFKA-19202: Enable KIP-1071 in streams_eos_test (#19700)
#127:Scheduled
trunk
2025-05-19 05:20:34 +08:00
0s
KAFKA-19256: Only send IQ metadata on assignment changes (#19691)
#123:Scheduled
#11399/merge
2025-05-19 05:40:21 +08:00
1s
MINOR: Add JmxReporter note to metric.reporters (#19706)
#117:Scheduled
trunk
2025-05-17 04:20:31 +08:00
0s
MINOR: Cleaning up code for share feature listener (#19715)
#107:Scheduled
trunk
2025-05-16 03:50:30 +08:00
0s
KAFKA-19116, KAFKA-19258: Handling share group member change events (#19666)
#101:Scheduled
trunk
2025-05-15 03:20:29 +08:00
0s
KAFKA-18847: Refactor OAuth layer to improve reusability 1/N (#19622)
#95:Scheduled
trunk
2025-05-14 11:00:25 +08:00
0s
MINOR: Add deprecation of listConsumerGroups to upgrade.html (#19684)
#88:Scheduled
trunk
2025-05-13 10:30:28 +08:00
0s
KAFKA-18695 Remove quorum=kraft and kip932 from all integration tests (#19633)
#80:Scheduled
trunk
2025-05-12 10:00:44 +08:00
0s
KAFKA-19068 Eliminate the duplicate type check in creating ControlRecord (#19346)
#76:Scheduled
trunk
2025-05-12 01:50:24 +08:00
0s
KAFKA-19229: Ignore background errors while closing share consumers. (Fix flaky test) (#19647)
#69:Scheduled
trunk
2025-05-10 09:00:25 +08:00
0s
KAFKA-19182 Move SchedulerTest to server module (#19608)
#62:Scheduled
trunk
2025-05-09 08:30:25 +08:00
0s
MINOR; Add `--standalone --ignore-formatted` formatter test (#19643)
#55:Scheduled
trunk
2025-05-08 08:00:25 +08:00
0s
KAFKA-19218: Add missing leader epoch to share group state summary response (#19602)
#50:Scheduled
trunk
2025-05-07 07:30:26 +08:00
0s
KAFKA-19232: Handle Share session limit reached exception in clients. (#19619)
#44:Scheduled
#19632/merge
2025-05-07 05:40:18 +08:00
1s
MINOR: replace .stream().forEach() with .forEach() (#19626)
#40:Scheduled
trunk
2025-05-05 06:30:26 +08:00
0s
MINOR: Change info log to debug for scheduled timer tasks. (#19624)
#34:Scheduled
trunk
2025-05-04 06:00:25 +08:00
0s
MINOR: remove @FunctionalInterface annotation (#19618)
#27:Scheduled
trunk
2025-05-03 05:30:23 +08:00
0s
KAFKA-19169: Enhance AuthorizerIntegrationTest for share group APIs (#19540)
#20:Scheduled
trunk
2025-05-02 05:00:26 +08:00
0s
HOTFIX: Fix IQv2EndpointToPartitionsIntegrationTest (#19597)
#14:Scheduled
trunk
2025-05-01 04:30:24 +08:00
0s
KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py (#19560)
#8:Scheduled
trunk
2025-04-30 04:00:24 +08:00
0s
MINOR: Cleanup OffsetFetchRequest/Response in MessageTest (#19576)
#2:Scheduled
trunk
2025-04-29 03:30:23 +08:00
0s