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)
#637:Scheduled
trunk
2025-10-08 03:30:20 +08:00
0s
MINOR: Adjust the timing for creating connect config (#20612)
#631:Scheduled
trunk
2025-10-07 06:55:01 +08:00
0s
MINOR: Enable streams rebalance protocol in EosIntegrationTest (#20592)
#626:Scheduled
trunk
2025-10-06 22:44:56 +08:00
0s
KAFKA-19748: fix metrics leak in Kafka Streams (#20633)
#621:Scheduled
trunk
2025-10-05 05:54:52 +08:00
0s
KAFKA-19744: Move restore time calculation to ChangelogMetadata (#20613)
#614: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)
#607:Scheduled
trunk
2025-10-03 04:55:01 +08:00
0s
KAFKA-19692 improve the docs of "clusterId" for AddRaftVoterOptions and RemoveRaftVoterOptions (#20555)
#600:Scheduled
#20566/merge
2025-10-03 04:04:20 +08:00
0s
KAFKA-15873: Filter topics before sorting (#19304)
#595:Scheduled
#20243/merge
2025-10-02 04:04:25 +08:00
0s
KAFKA-15873: Filter topics before sorting (#19304)
#592:Scheduled
trunk
2025-10-01 03:54:57 +08:00
0s
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
#584:Scheduled
trunk
2025-09-29 11:11:23 +08:00
0s
KAFKA-14604: SASL session expiration time will be overflowed when calculation (#18526)
#580:Scheduled
trunk
2025-09-29 10:04:28 +08:00
0s
KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement (#20286)
#576:Scheduled
#18935/merge
2025-08-04 04:33:35 +08:00
0s
KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
#571:Scheduled
#20274/merge
2025-08-03 04:33:28 +08:00
0s
MINOR: add test for `kafka-consumer-groups.sh` should not fail when partition offline (#20235)
#564:Scheduled
trunk
2025-08-01 09:38:40 +08:00
0s
KAFKA-19489; Extra validation when formatting a node (#20136)
#558:Scheduled
trunk
2025-07-31 07:28:03 +08:00
0s
KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline (#20218)
#553:Scheduled
trunk
2025-07-30 06:50:18 +08:00
0s
KAFKA-19551: Remove the handling of FatalExitError in RemoteStorageThreadPool (#20245)
#546:Scheduled
trunk
2025-07-29 06:20:16 +08:00
0s
MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json (#20239)
#541: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)
#538:Scheduled
trunk
2025-07-28 03:30:07 +08:00
0s
MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap (#20205)
#532:Scheduled
#20008/merge
2025-07-27 04:30:12 +08:00
0s
MINOR: typo in javadoc (#20113)
#528:Scheduled
trunk
2025-07-25 04:28:54 +08:00
0s
KAFKA-19523: Gracefully handle error while building remoteLogAuxState (#20201)
#522:Scheduled
trunk
2025-07-24 09:59:25 +08:00
0s
KAFKA-19503: Deprecate MX4j support (#20208)
#514:Scheduled
trunk
2025-07-23 07:34:13 +08:00
0s
KAFKA-19476: Removing AtomicBoolean for findNextFetchOfffset (1/N) (#20207)
#509:Scheduled
trunk
2025-07-22 04:35:37 +08:00
0s
KAFKA-19522: avoid electing fenced lastKnownLeader (#20200)
#502:Scheduled
trunk
2025-07-21 04:05:38 +08:00
0s
MINOR: Remove unnecessary dependencies from coordinator-common (follow up to pr#20089) (#20194)
#496:Scheduled
trunk
2025-07-20 03:36:01 +08:00
0s
MINOR: Correct RemoteLogManager.getLeaderEpochEntries comment (#20181)
#488:Scheduled
trunk
2025-07-19 11:15:42 +08:00
0s
MINOR: Migrate CoordinatorLoaderImpl from Scala to Java (#20089)
#481:Scheduled
trunk
2025-07-18 10:45:38 +08:00
0s
KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)
#474:Scheduled
trunk
2025-07-17 10:15:40 +08:00
0s
MINOR: Refactor LockUtils and improve comments (follow up to KAFKA-19390) (#20131)
#466:Scheduled
trunk
2025-07-16 17:55:54 +08:00
0s
KAFKA-19452: Fix flaky test LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments (#20121)
#458:Scheduled
trunk
2025-07-15 09:16:31 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#453:Scheduled
#19082/merge
2025-07-15 05:25:24 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#450:Scheduled
trunk
2025-07-14 05:25:25 +08:00
0s
MINOR: Moving the rollback out of lock in share partition (#20153)
#446:Scheduled
trunk
2025-07-13 03:30:23 +08:00
0s
KAFKA-19485: Added check before sending acknowledgements on initial epoch. (#20135)
#439:Scheduled
trunk
2025-07-11 07:15:32 +08:00
0s
KAFKA-19477: Sticky Assignor JMH Benchmark (#20118)
#432:Scheduled
trunk
2025-07-10 06:45:33 +08:00
0s
KAFKA-18288: Fix Streams CLI describe (#20099)
#424:Scheduled
trunk
2025-07-09 06:15:34 +08:00
0s
KAFKA-19315 Move ControllerMutationQuotaManager to server module (#19807)
#417:Scheduled
#20112/merge
2025-07-09 05:25:24 +08:00
0s
MINOR: Use <code> block instead of backtick (#20107)
#412:Scheduled
trunk
2025-07-07 05:15:31 +08:00
0s
KAFKA-19397: Ensure consistent metadata usage in produce request and response (#19964)
#407:Scheduled
#20102/merge
2025-07-07 05:25:24 +08:00
0s
KAFKA-19363: Finalize heterogeneous simple share assignor (#20074)
#401:Scheduled
trunk
2025-07-05 04:15:32 +08:00
0s
MINOR: Fix the tests in LogValidatorTest (#20093)
#395:Scheduled
trunk
2025-07-04 03:45:33 +08:00
0s
KAFKA-19463: nextFetchOffset does not take ongoing state transition into account (#20080)
#390:Scheduled
trunk
2025-07-03 11:25:31 +08:00
0s
MINOR: Remove threadNamePrefix parameter from ReplicaManager and ReplicaFetcherManager (#20069)
#384:Scheduled
trunk
2025-07-02 10:55:33 +08:00
0s
MINOR: remove unused FlattenedIterator (#20067)
#378:Scheduled
trunk
2025-07-01 10:25:33 +08:00
0s
MINOR: Fix typo in AssignmentsManager (#20059)
#373:Scheduled
trunk
2025-06-30 18:05:35 +08:00
0s
KAFKA-19420 Don't export SocketServer from ClusterInstance (#20002)
#368:Scheduled
#19265/merge
2025-06-30 05:25:30 +08:00
0s
KAFKA-19420 Don't export SocketServer from ClusterInstance (#20002)
#364:Scheduled
trunk
2025-06-29 05:25:37 +08:00
0s
KAFKA-19436: Restrict cache update for ongoing batch/offset state (#20041)
#356:Scheduled
trunk
2025-06-27 08:25:36 +08:00
0s
MINOR: Reject requests using unsupported features in KIP-1071 (#20031)
#349:Scheduled
trunk
2025-06-26 07:55:32 +08:00
0s
KAFKA-19244: Fix flaky streams offsets reset integration test (#20027)
#340:Scheduled
trunk
2025-06-25 07:25:37 +08:00
0s
MINOR: Change snapshot epoch type to int32 in schema. (#20016)
#334:Scheduled
trunk
2025-06-24 06:55:35 +08:00
0s
MINOR: Restore original behavior of GroupAuthorizerIntegrationTest (#19968)
#329:Scheduled
trunk
2025-06-23 06:25:32 +08:00
0s
MINOR: changed the test testShareFetchRequestSuccessfulSharingBetweenMultipleConsumers to remove ambiguity (#19997)
#324:Scheduled
trunk
2025-06-22 22:15:33 +08:00
0s
MINOR: Reduce logging in persister. (#19998)
#318:Scheduled
trunk
2025-06-21 05:25:34 +08:00
0s
MINOR : Fix possible flake in ShareConsumerTest:testConsumerCloseInGroupSequential (#19986)
#311:Scheduled
trunk
2025-06-20 04:55:32 +08:00
0s
KAFKA-19413: Extended AuthorizerIntegrationTest to cover StreamsGroupDescribe (#19981)
#305: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)
#299:Scheduled
trunk
2025-06-18 03:56:47 +08:00
0s
KAFKA-18486 Remove ReplicaManager#becomeLeaderOrFollower from testFencedErrorCausedByBecomeLeader and other similar methods (#19966)
#295:Scheduled
trunk
2025-06-17 11:36:44 +08:00
0s
MINOR: Fix typo to actually use rocksdb setOptimizeFiltersForHits (#19837)
#289:Scheduled
trunk
2025-06-16 11:06:44 +08:00
0s
KAFKA-18486: Migrate ReplicaManagerTest to use applyDelta (#19954)
#284:Scheduled
trunk
2025-06-16 02:56:44 +08:00
0s
MINOR: rename exception `e` to `swallow` where appropriate (#19948)
#279: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)
#271:Scheduled
trunk
2025-06-13 09:36:45 +08:00
0s
KAFKA-18486 Update testClearPurgatoryOnBecomingFollower etc with KRaft mechanism in ReplicaManagerTest (#19924)
#266:Scheduled
trunk
2025-06-12 17:16:46 +08:00
0s
MINOR: Remove unused code from storage classes (#19853)
#259:Scheduled
trunk
2025-06-11 08:36:45 +08:00
0s
KAFKA-19271: allow intercepting internal method call (#19832)
#253:Scheduled
trunk
2025-06-10 08:06:43 +08:00
0s
KAFKA-19042 Move PlaintextConsumerSubscriptionTest to client-integration-tests module (#19827)
#246:Scheduled
trunk
2025-06-09 07:36:41 +08:00
0s
KAFKA-19295: Remove AsyncKafkaConsumer event ID generation (#19915)
#242:Scheduled
trunk
2025-06-08 07:06:46 +08:00
0s
KAFKA-19369: Add group.share.assignors config and integration test (#19900)
#236:Scheduled
trunk
2025-06-07 06:36:44 +08:00
0s
MINOR: clean KafkaConsumer tests (#19669)
#230:Scheduled
trunk
2025-06-06 06:06:44 +08:00
0s
KAFKA-18573: Add support for OAuth jwt-bearer grant type (#19754)
#224:Scheduled
trunk
2025-06-05 05:36:47 +08:00
0s
KAFKA-19353: Upgrade note and initial docs for KIP-932 (#19863)
#218:Scheduled
trunk
2025-06-04 05:06:44 +08:00
0s
KAFKA-19321: Added share_consumer_performance.py and related system tests (#19836)
#213: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)
#208:Scheduled
#18738/merge
2025-06-03 05:26:35 +08:00
0s
KAFKA-19042 Move GroupAuthorizerIntegrationTest to clients-integration-tests module (#19685)
#204:Scheduled
trunk
2025-06-01 03:36:41 +08:00
0s
KAFKA-19042 Move GroupAuthorizerIntegrationTest to clients-integration-tests module (#19685)
#200:Scheduled
trunk
2025-06-01 03:30:34 +08:00
0s
KAFKA-19042 move ConsumerWithLegacyMessageFormatIntegrationTest to clients-integration-tests module (#19810)
#194:Scheduled
trunk
2025-05-30 18:56:43 +08:00
0s
KAFKA-19347 Don't update timeline data structures in createAcls (#19840)
#188: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)
#181:Scheduled
trunk
2025-05-28 09:50:28 +08:00
0s
KAFKA-19322 Remove the DelayedOperation constructor that accepts an external lock (#19798)
#174: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)
#168:Scheduled
trunk
2025-05-26 08:50:24 +08:00
0s
KAFKA-19313 Replace LogOffsetMetadata#UNIFIED_LOG_UNKNOWN_OFFSET by UnifiedLog.UNKNOWN_OFFSET (#19767)
#163:Scheduled
trunk
2025-05-25 16:30:30 +08:00
0s
KAFKA-19260 Move LoggingController to server module (#19687)
#157:Scheduled
trunk
2025-05-24 07:50:22 +08:00
0s
KAFKA-18904: Add Admin#listConfigResources [2/N] (#19743)
#151:Scheduled
trunk
2025-05-23 07:20:36 +08:00
0s
KAFKA-4650: Add unit tests for GraphNode class (#18951)
#146:Scheduled
trunk
2025-05-22 15:00:24 +08:00
0s
MINOR: Cleanup Share Coordinator (#19770)
#139:Scheduled
trunk
2025-05-21 06:20:25 +08:00
0s
KAFKA-17747: [3/N] Get rid of TopicMetadata in SubscribedTopicDescriberImpl (#19611)
#133:Scheduled
trunk
2025-05-20 05:50:34 +08:00
0s
KAFKA-19202: Enable KIP-1071 in streams_eos_test (#19700)
#128:Scheduled
trunk
2025-05-19 05:20:34 +08:00
0s
KAFKA-19256: Only send IQ metadata on assignment changes (#19691)
#124:Scheduled
#11399/merge
2025-05-19 05:40:20 +08:00
0s
MINOR: Add JmxReporter note to metric.reporters (#19706)
#118:Scheduled
trunk
2025-05-17 04:20:31 +08:00
0s
MINOR: Cleaning up code for share feature listener (#19715)
#108:Scheduled
trunk
2025-05-16 03:50:30 +08:00
0s
KAFKA-18666: Controller-side monitoring for broker shutdown and startup (#19586)
#103:Scheduled
trunk
2025-05-15 11:30:31 +08:00
0s
KAFKA-18847: Refactor OAuth layer to improve reusability 1/N (#19622)
#96:Scheduled
trunk
2025-05-14 11:00:25 +08:00
0s
MINOR: Add deprecation of listConsumerGroups to upgrade.html (#19684)
#89:Scheduled
trunk
2025-05-13 10:30:27 +08:00
0s
KAFKA-18695 Remove quorum=kraft and kip932 from all integration tests (#19633)
#81:Scheduled
trunk
2025-05-12 10:00:44 +08:00
0s
KAFKA-19068 Eliminate the duplicate type check in creating ControlRecord (#19346)
#77:Scheduled
trunk
2025-05-12 01:50:24 +08:00
0s
KAFKA-19229: Ignore background errors while closing share consumers. (Fix flaky test) (#19647)
#70:Scheduled
trunk
2025-05-10 09:00:25 +08:00
0s
KAFKA-19182 Move SchedulerTest to server module (#19608)
#63:Scheduled
trunk
2025-05-09 08:30:25 +08:00
0s
MINOR; Add `--standalone --ignore-formatted` formatter test (#19643)
#56:Scheduled
trunk
2025-05-08 08:00:25 +08:00
0s
KAFKA-19218: Add missing leader epoch to share group state summary response (#19602)
#51:Scheduled
trunk
2025-05-07 07:30:26 +08:00
0s
KAFKA-19232: Handle Share session limit reached exception in clients. (#19619)
#45:Scheduled
#19632/merge
2025-05-07 05:40:18 +08:00
0s
MINOR: replace .stream().forEach() with .forEach() (#19626)
#41:Scheduled
trunk
2025-05-05 06:30:26 +08:00
0s
MINOR: Change info log to debug for scheduled timer tasks. (#19624)
#35:Scheduled
trunk
2025-05-04 06:00:25 +08:00
0s
MINOR: remove @FunctionalInterface annotation (#19618)
#28:Scheduled
trunk
2025-05-03 05:30:23 +08:00
0s
KAFKA-19169: Enhance AuthorizerIntegrationTest for share group APIs (#19540)
#21:Scheduled
trunk
2025-05-02 05:00:25 +08:00
0s
HOTFIX: Fix IQv2EndpointToPartitionsIntegrationTest (#19597)
#15:Scheduled
trunk
2025-05-01 04:30:24 +08:00
0s
KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py (#19560)
#9:Scheduled
trunk
2025-04-30 04:00:24 +08:00
0s
MINOR: Cleanup OffsetFetchRequest/Response in MessageTest (#19576)
#3:Scheduled
trunk
2025-04-29 03:30:23 +08:00
0s