Messages by Thread
-
(kafka-site) branch MINOR-add-josep-prat-key created (now 055a9b80)
jlprat
-
(kafka) branch 3.8 updated (facbab272fb -> d94a28b4a4f)
satishd
-
(kafka) branch trunk updated (68070c94a6b -> af86e56fcdf)
chia7712
-
(kafka) branch trunk updated (31c55b630b6 -> 68070c94a6b)
manikumar
-
(kafka) branch trunk updated: add slf4jlog4j in tool (#16260)
showuon
-
(kafka) branch 3.7 updated: KAFKA-9228: Restart tasks on runtime-only connector config changes (#16053)
cegerton
-
(kafka) branch trunk updated (1426e8e9206 -> eec8fd6a98c)
cegerton
-
(kafka) branch trunk updated (f359908fcdc -> 1426e8e9206)
lucasbru
-
(kafka) branch trunk updated (049cfeac027 -> f359908fcdc)
satishd
-
(kafka) branch 3.8 updated (a2760e0131e -> 113baae977c)
manikumar
-
(kafka) branch 3.8 updated: MINOR: Rename uniform assignor's internal builders (#16233)
dajac
-
(kafka) branch trunk updated: MINOR: Rename uniform assignor's internal builders (#16233)
dajac
-
(kafka) branch 3.8 updated: KAFKA-14509; [4/4] Handle includeAuthorizedOperations in ConsumerGroupDescribe API (#16158)
dajac
-
(kafka) branch trunk updated (40de07dab52 -> fa01c0c10f1)
mimaison
-
(kafka) branch trunk updated: KAFKA-14509; [4/4] Handle includeAuthorizedOperations in ConsumerGroupDescribe API (#16158)
dajac
-
(kafka) branch trunk updated: KAFKA-16448: Add ProcessingExceptionHandler in Streams configuration (#16188)
cadonna
-
(kafka) branch trunk updated: KAFKA-15718: Refactor UncleanLeaderElectionTest to enable KRaft later (#16157)
showuon
-
(kafka) branch trunk updated: MINOR: Add fast_commit ext4 config to ops docs (#15496)
mimaison
-
(kafka) branch trunk updated: [MINOR] KAFKA-16373: KIP-1028: Modifying dockerfile comments (#16261)
manikumar
-
(kafka) branch trunk updated (e5b8712993d -> 84b2d5bedf4)
manikumar
-
(kafka) branch trunk updated (34afdb96275 -> e5b8712993d)
chia7712
-
(kafka) branch 3.8 updated: KAFKA-15045: (KIP-924 pt. 20) Custom task assignment configuration fix (#16245)
ableegoldman
-
(kafka) branch trunk updated (824900b97a3 -> 34afdb96275)
ableegoldman
-
(kafka) branch 3.8 updated: KAFKA-15045: (KIP-924 pt. 18) Better assignment testing (#16201)
ableegoldman
-
(kafka) branch trunk updated (b8b248b1e8b -> 824900b97a3)
ableegoldman
-
(kafka) branch trunk updated: KAFKA-16920: close BrokerLifecycleManager in tests (#16252)
soarez
-
(kafka) branch trunk updated (3d5d1504f79 -> 816209d1877)
chia7712
-
(kafka) branch trunk updated: KAFKA-16878 Remove powermock and easymock from code base (#16236)
chia7712
-
(kafka) branch 3.7 updated: KAFKA-16886: Detect replica demotion in AssignmentsManager (#16232)
soarez
-
(kafka) branch 3.8 updated: KAFKA-16886: Detect replica demotion in AssignmentsManager (#16232)
soarez
-
(kafka) branch trunk updated (5a5a2921462 -> 55945580472)
soarez
-
(kafka) branch 3.8 updated: MINOR: Fix broken ReassignPartitionsCommandTest test (#16251)
soarez
-
(kafka) branch 3.7 updated: MINOR: Fix broken ReassignPartitionsCommandTest test (#16251)
soarez
-
(kafka) branch trunk updated: MINOR: Fix broken ReassignPartitionsCommandTest test (#16251)
soarez
-
(kafka) branch trunk updated (d13a693ea76 -> 96036aee855)
showuon
-
(kafka) branch trunk updated: KAFKA-16916: Disable blocking test temporarily (#16248)
showuon
-
(kafka) branch trunk updated: MINOR: Remove AK 1.0.0 reference from NetworkClient.java (#16223)
chia7712
-
(kafka) branch 3.8 updated: KAFKA-16535: Implement AddVoter, RemoveVoter, UpdateVoter RPCs
cmccabe
-
(kafka) branch 3.8 updated: MINOR: Update docs for for KIP-671 (#16247)
mjsax
-
(kafka) branch trunk updated: MINOR: Update docs for for KIP-671 (#16247)
mjsax
-
(kafka) branch 3.8 updated: MINOR: update all-latency-max, range-latency-avg|max and add prefix-scan documentation (#16182)
mjsax
-
(kafka) branch trunk updated: MINOR: update all-latency-max, range-latency-avg|max and add prefix-scan documentation (#16182)
mjsax
-
(kafka) branch 3.8 updated: KAFKA-16911: Update docs for KIP-862 (#16246)
mjsax
-
(kafka) branch trunk updated: KAFKA-16911: Update docs for KIP-862 (#16246)
mjsax
-
(kafka) branch 3.8 updated: KAFKA-16493: Avoid unneeded subscription regex check if metadata version unchanged (#15869)
mjsax
-
(kafka) branch trunk updated (e41e54d0a00 -> 5cd6944eaac)
mjsax
-
(kafka) branch trunk updated: MINOR: Remove unnecessary log4j-appender dependency and tweak explicit log4j dependency (#12148)
mimaison
-
(kafka) branch 3.7 updated: KAFKA-16606 Gate JBOD configuration on 3.7-IV2 (#15834)
soarez
-
(kafka) branch 3.8 updated: KAFKA-16606 Gate JBOD configuration on 3.7-IV2 (#15834)
soarez
-
(kafka) branch trunk updated (d6cd83e2fb2 -> 7c0fff7c36d)
soarez
-
(kafka) branch 3.8 updated: KAFKA-16200: Enforce that RequestManager implementations respect user-provided timeout (#16031)
cadonna
-
(kafka) branch trunk updated (247132569e7 -> d6cd83e2fb2)
cadonna
-
(kafka) branch 3.8 updated: KAFKA-16786: Remove old assignment strategy usage in new consumer (#16214)
lucasbru
-
(kafka) branch trunk updated (271a1b42cd5 -> 247132569e7)
chia7712
-
(kafka) branch trunk updated (c01279b92ac -> 271a1b42cd5)
chia7712
-
(kafka) branch trunk updated (ee834d9214b -> c01279b92ac)
davidarthur
-
(kafka) branch 3.8 updated: KAFKA-15045: (KIP-924 pt. 19) Update to new AssignmentConfigs (#16219)
ableegoldman
-
(kafka) branch trunk updated: KAFKA-15045: (KIP-924 pt. 19) Update to new AssignmentConfigs (#16219)
ableegoldman
-
(kafka) branch 3.8 updated: KAFKA-16903: Consider produce error of different task (#16222)
mjsax
-
(kafka) branch trunk updated: KAFKA-16903: Consider produce error of different task (#16222)
mjsax
-
(kafka) branch trunk updated (79ea7d6122a -> 7d832cf74fd)
dajac
-
(kafka) branch trunk updated: MINOR: Various cleanups in clients (#16193)
mimaison
-
(kafka) branch trunk updated: KAFKA-16884 Refactor RemoteLogManagerConfig with AbstractConfig (#16199)
chia7712
-
(kafka) branch trunk updated: MINOR: Cleanup the storage module unit tests (#16202)
chia7712
-
(kafka) branch trunk updated: MINOR: Added test for ClusterConfig#displayTags (#16110)
chia7712
-
(kafka) branch trunk updated (b74b182841a -> ebe1e964ffb)
cadonna
-
(kafka) branch trunk updated: KAFKA-16786: Remove old assignment strategy usage in new consumer (#16214)
lucasbru
-
(kafka) branch 3.8 updated: KAFKA-16530: Fix high-watermark calculation to not assume the leader is in the voter set (#16079)
showuon
-
(kafka) branch trunk updated: KAFKA-16530: Fix high-watermark calculation to not assume the leader is in the voter set (#16079)
showuon
-
(kafka) branch trunk updated: KAFKA-16541 Fix potential leader-epoch checkpoint file corruption (#15993)
junrao
-
(kafka) branch 3.8 updated: KAFKA-16814 KRaft broker cannot startup when `partition.metadata` is missing (#16165)
showuon
-
(kafka) branch 3.8 updated (1f6c5dc5df4 -> e82731f0c6c)
ableegoldman
-
(kafka) branch 3.7 updated: KAFKA-12317: Update FK-left-join documentation (#15689)
mjsax
-
(kafka) branch 3.8 updated: KAFKA-12317: Update FK-left-join documentation (#15689)
mjsax
-
(kafka) branch trunk updated (1134520decf -> 7763243752d)
mjsax
-
(kafka) branch 3.8 updated: KAFKA-16573: Specify node and store where serdes are needed (#15790)
mjsax
-
(kafka) branch 3.7 updated: MINOR: Fix error in testRestartBrokerNoErrorIfMissingPartitionMetadata (#16216)
soarez
-
(kafka) branch trunk updated: KAFKA-16573: Specify node and store where serdes are needed (#15790)
mjsax
-
(kafka) branch trunk updated (0109a3f7189 -> 896af1b2f2f)
chia7712
-
(kafka) branch trunk updated: KAFKA-15045: (KIP-924 pt. 17) State store computation fixed (#16194)
ableegoldman
-
(kafka) branch 3.8 updated: KAFKA-16858: Throw DataException from validateValue on array and map schemas without inner schemas (#16161)
gharris
-
(kafka) branch trunk updated: KAFKA-16858: Throw DataException from validateValue on array and map schemas without inner schemas (#16161)
gharris
-
(kafka) branch trunk updated (bd9d68f24a5 -> f2aafcc66fa)
chia7712
-
(kafka) branch 3.8 updated: KAFKA-15265: Integrate RLMQuotaManager for throttling fetches from remote storage (#16071)
satishd
-
(kafka) branch trunk updated: KAFKA-15265: Integrate RLMQuotaManager for throttling fetches from remote storage (#16071)
satishd
-
(kafka) branch 3.8 updated: KAFKA-16888 Fix failed StorageToolTest.testFormatSucceedsIfAllDirectoriesAreAvailable and StorageToolTest.testFormatEmptyDirectory (#16186)
chia7712
-
(kafka) branch trunk updated (02c794dfd3b -> 62e5cce1841)
chia7712
-
(kafka) branch trunk updated: KAFKA-15776: Introduce remote.fetch.max.timeout.ms to configure DelayedRemoteFetch timeout (#14778)
showuon
-
(kafka) branch 3.8 updated: MINOR: Adjust validateOffsetCommit/Fetch in ConsumerGroup to ensure compatibility with classic protocol members (#16145)
dajac
-
(kafka) branch trunk updated: MINOR: Adjust validateOffsetCommit/Fetch in ConsumerGroup to ensure compatibility with classic protocol members (#16145)
dajac
-
(kafka) branch trunk updated: KAFKA-16740: Adding skeleton code for Share Fetch and Acknowledge RPC (KIP-932) (#16184)
manikumar
-
(kafka) branch trunk updated: KAFKA-16483: Remove preAppendErrors from createPutCacheCallback (#16105)
showuon
-
(kafka) branch 3.7 updated: KAFKA-16814 KRaft broker cannot startup when `partition.metadata` is missing (#16165)
showuon
-
(kafka) branch trunk updated: KAFKA-16814 KRaft broker cannot startup when `partition.metadata` is missing (#16165)
showuon
-
(kafka) branch trunk updated (7e0caad96eb -> d652f5cf54c)
showuon
-
(kafka) branch trunk updated: MINOR: Cleanup unused references in core (#16192)
chia7712
-
(kafka) branch trunk updated (9ceed8f18f4 -> 9821acaab6f)
chia7712
-
(kafka) branch trunk updated (8b3c77c6711 -> 9ceed8f18f4)
cmccabe
-
(kafka) branch 3.8 updated: KAFKA-15305 The background thread should try to process the remaining task until the shutdown timer is expired. (#16156)
chia7712
-
(kafka) branch trunk updated (cda2df5feb0 -> 8b3c77c6711)
chia7712
-
(kafka) branch trunk updated: KAFKA-16882 Migrate RemoteLogSegmentLifecycleTest to ClusterInstance infra (#16180)
chia7712
-
(kafka) branch 3.8 updated: MINOR: Fix return tag on Javadocs for consumer group-related Admin methods (#16197)
cegerton
-
(kafka) branch 3.7 updated: MINOR: Fix return tag on Javadocs for consumer group-related Admin methods (#16197)
cegerton
-
(kafka) branch trunk updated (5ce4b91dfa6 -> 2b4779840cb)
cegerton
-
(kafka) branch trunk updated: KAFKA-15045: (KIP-924 pt. 16) TaskAssignor.onAssignmentComputed handling (#16147)
ableegoldman
-
(kafka) branch trunk updated (16359e70d3a -> 55d38efcc55)
mimaison
-
(kafka) branch 3.7 updated: KAFKA-16583: Handle PartitionChangeRecord without directory IDs (#16118)
soarez
-
(kafka) branch 3.8 updated: KAFKA-16583: Handle PartitionChangeRecord without directory IDs (#16118)
soarez
-
(kafka) branch trunk updated: KAFKA-16583: Handle PartitionChangeRecord without directory IDs (#16118)
soarez
-
(kafka) branch 3.8 updated (7404fdffa67 -> ebc68f00e4c)
dajac
-
(kafka) branch 3.7 updated: KAFKA-16837, KAFKA-16838: Ignore task configs for deleted connectors, and compare raw task configs before publishing them (#16122)
cegerton
-
(kafka) branch trunk updated (7d82f7625e5 -> 078dd9a311a)
dajac
-
(kafka) branch 3.8 updated: KAFKA-16837, KAFKA-16838: Ignore task configs for deleted connectors, and compare raw task configs before publishing them (#16122)
cegerton
-
(kafka) branch trunk updated: MINOR: Log time taken to compute the target assignment (#16185)
dajac
-
(kafka) branch trunk updated (a08db65670d -> 0409003c439)
cegerton
-
(kafka) branch trunk updated: KAFKA-16888 Fix failed StorageToolTest.testFormatSucceedsIfAllDirectoriesAreAvailable and StorageToolTest.testFormatEmptyDirectory (#16186)
chia7712
-
(kafka) branch 3.8 updated: KAFKA-16047: Use REQUEST_TIMEOUT_MS_CONFIG in AdminClient.fenceProducers (#16151)
edocomar
-
(kafka) branch 3.7 updated: KAFKA-16047: Use REQUEST_TIMEOUT_MS_CONFIG in AdminClient.fenceProducers (#16151)
edocomar
-
(kafka) branch trunk updated: KAFKA-16047: Use REQUEST_TIMEOUT_MS_CONFIG in AdminClient.fenceProducers (#16151)
edocomar
-
(kafka) branch trunk updated: MINOR migrate ReassignPartitionsIntegrationTest to use ClusterTestExtensions (#15675)
chia7712
-
(kafka) branch 3.8 updated: KAFKA-16664; Re-add EventAccumulator.poll(long, TimeUnit) (#16144)
dajac
-
(kafka) branch trunk updated: KAFKA-16664; Re-add EventAccumulator.poll(long, TimeUnit) (#16144)
dajac
-
(kafka) branch trunk updated (53d592e369f -> 64c50a274ba)
chia7712
-
(kafka) branch 3.8 updated: MINOR: Fix type in MetadataVersion.IBP_4_0_IV0 (#16181)
jolshan
-
(kafka) branch trunk updated: MINOR: Fix type in MetadataVersion.IBP_4_0_IV0 (#16181)
jolshan
-
(kafka) branch trunk updated: KAFKA-16715: Create KafkaShareConsumer interfaces (#16134)
manikumar
-
(kafka) branch 3.8 updated: KAFKA-16105: Reset read offsets when seeking to beginning in TBRLMM (#15165)
gharris
-
(kafka) branch 3.7 updated: KAFKA-16105: Reset read offsets when seeking to beginning in TBRLMM (#15165)
gharris
-
(kafka) branch trunk updated (c6c39c0062b -> 8a882a77a47)
gharris
-
(kafka) branch trunk updated: MINOR: Use project path instead of name for spotlessApplyModules in Gradle script (#16177)
cegerton
-
(kafka) branch 3.8 updated (495ec16fb23 -> 9c72048a883)
dajac
-
(kafka) branch trunk updated: KAFKA-16861: Don't convert to group to classic if the size is larger than group max size. (#16163)
dajac
-
(kafka) branch trunk updated (5cbc1d616ac -> 979f8d9aa3e)
dajac
-
(kafka) branch 3.7 updated: KAFKA-16881: InitialState type leaks into the Connect REST API OpenAPI spec (#16175)
cegerton
-
(kafka) branch 3.8 updated: KAFKA-16881: InitialState type leaks into the Connect REST API OpenAPI spec (#16175)
cegerton
-
(kafka) branch trunk updated (04e6ef47508 -> 5cbc1d616ac)
cegerton
-
(kafka) branch trunk updated: KAFKA-15156 Update cipherInformation correctly in DefaultChannelMetadataRegistry (#16169)
chia7712
-
(kafka) branch trunk updated: MINOR: Upgrade scala-logging to 3.9.5 (#15914)
viktor
-
(kafka) branch trunk updated (8f82f14a483 -> 734d309a297)
clolov
-
(kafka) branch trunk updated: KAFKA-16713: Define initial set of RPCs for KIP-932 (#16022)
manikumar
-
(kafka) branch trunk updated (342e69192f6 -> 85076932293)
chia7712
-
(kafka) branch trunk updated (0c9c1d405d3 -> 342e69192f6)
chia7712
-
(kafka) branch trunk updated: MINOR: Fix missing wait topic finished in TopicBasedRemoteLogMetadataManagerRestartTest (#16171)
chia7712
-
(kafka) branch trunk updated: KAFKA-16785 Migrate TopicBasedRemoteLogMetadataManagerRestartTest to new test infra (#16170)
chia7712
-
(kafka) branch trunk updated: KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest (#16164)
chia7712
-
(kafka) branch 3.7 updated: KAFKA-16807 DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions (#16042)
chia7712
-
(kafka) branch 3.8 updated: KAFKA-16807 DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions (#16042)
chia7712
-
(kafka) branch trunk updated: KAFKA-16807 DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions (#16042)
chia7712
-
(kafka) branch 3.8 updated: KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2 (#15945)
soarez
-
(kafka) branch 3.7 updated: KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2
soarez
-
(kafka) branch trunk updated: KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2 (#15945)
soarez
-
(kafka) branch trunk updated: Minor: Add URL to log for Connect RestClient (#16166)
cegerton
-
(kafka) branch trunk updated: MINOR: reduce the test suits of consumer group tools (#16155)
chia7712
-
(kafka) branch trunk updated: KAFKA-16574 The metrics of LogCleaner disappear after reconfiguration (#15863)
chia7712
-
(kafka) branch trunk updated (fb566e48bf0 -> db2a09fa907)
chia7712
-
(kafka) branch 3.8 updated: KAFKA-16639 Ensure HeartbeatRequestManager generates leave request regardless of in-flight heartbeats. (#16017)
chia7712
-
(kafka) branch 3.8 updated: KAFKA-16864; Optimize uniform (homogenous) assignor (#16088)
dajac
-
(kafka) branch trunk updated: KAFKA-16864; Optimize uniform (homogenous) assignor (#16088)
dajac
-
(kafka) branch trunk updated: KAFKA-16639 Ensure HeartbeatRequestManager generates leave request regardless of in-flight heartbeats. (#16017)
chia7712
-
(kafka) branch 3.8 updated (0971924ebc7 -> 5257451646a)
dajac
-
(kafka) branch trunk updated: KAFKA-16860; [2/2] Introduce group.version feature flag (#16149)
dajac
-
(kafka) branch trunk updated (f8ad9ee8920 -> ba61ff0cd94)
dajac
-
(kafka) branch trunk updated: MINOR: update all-latency-avg documentation (#16148)
mjsax
-
(kafka) branch trunk updated (cdd4455cb8b -> 9c2b1b8d0bf)
gharris
-
(kafka) branch trunk updated: KAFKA-16866 Used the right constant in RemoteLogManagerTest#testFetchQuotaManagerConfig (#16152)
chia7712
-
(kafka) branch trunk updated (7e81cc5e68a -> b6d0fb055d1)
chia7712
-
(kafka) branch trunk updated (21caf6b123d -> 7e81cc5e68a)
jlprat
-
(kafka) branch trunk updated: KAFKA-16629 Add broker-related tests to ConfigCommandIntegrationTest (#15840)
chia7712
-
(kafka) branch 3.8 updated (b0fb2ac06d8 -> 0971924ebc7)
jlprat
-
(kafka) branch 3.8 created (now b0fb2ac06d8)
jlprat
-
(kafka) branch trunk updated: KAFKA-16824: Utils.getHost and Utils.getPort do not catch a lot of invalid host and ports. (#16048)
showuon
-
(kafka) branch trunk updated (3d125a23224 -> eb39031cd03)
lucasbru
-
(kafka) branch trunk updated (76d1f18e42d -> 3d125a23224)
showuon
-
(kafka) branch trunk updated: Revert "KAFKA-16448: Add ProcessingExceptionHandler interface and implementations (#16090)" (#16142)
cadonna
-
(kafka) branch trunk updated (370e5ea1f81 -> b0fb2ac06d8)
satishd
-
(kafka) branch trunk updated: KAFKA-15045: (KIP-924 pt. 15) Implement #defaultStandbyTaskAssignment and finish rack-aware standby optimization (#16129)
ableegoldman
-
(kafka) branch trunk updated: KAFKA-16308 [2/N]: Allow unstable feature versions and rename unstable metadata config (#16130)
jolshan