ShivsundarR commented on code in PR #19886:
URL: https://github.com/apache/kafka/pull/19886#discussion_r2218323811
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java:
##
@@ -144,6 +145,18 @@ public void tryConnect(Node node) {
*
[
https://issues.apache.org/jira/browse/KAFKA-19523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-19523:
-
Description:
Improve the error handling while building the remote-log-auxiliary
kamalcph commented on code in PR #20201:
URL: https://github.com/apache/kafka/pull/20201#discussion_r2218222799
##
core/src/main/java/kafka/server/TierStateMachine.java:
##
@@ -230,6 +230,10 @@ private Long buildRemoteLogAuxState(TopicPartition
topicPartition,
}
[
https://issues.apache.org/jira/browse/KAFKA-19527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HongYi Chen reassigned KAFKA-19527:
---
Assignee: HongYi Chen (was: Chia-Ping Tsai)
> improve the docs of LogDirDescription for re
Chia-Ping Tsai created KAFKA-19527:
--
Summary: improve the docs of LogDirDescription for remote stroage
Key: KAFKA-19527
URL: https://issues.apache.org/jira/browse/KAFKA-19527
Project: Kafka
satishd commented on code in PR #20201:
URL: https://github.com/apache/kafka/pull/20201#discussion_r2218192589
##
core/src/main/java/kafka/server/TierStateMachine.java:
##
@@ -230,6 +230,10 @@ private Long buildRemoteLogAuxState(TopicPartition
topicPartition,
}
karuturi commented on code in PR #20192:
URL: https://github.com/apache/kafka/pull/20192#discussion_r2218192770
##
streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java:
##
@@ -23,6 +23,7 @@
* @see org.apache.kafka.streams.StreamsConfig
*/
@Supp
karuturi commented on code in PR #20192:
URL: https://github.com/apache/kafka/pull/20192#discussion_r2218192266
##
streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java:
##
@@ -23,6 +23,7 @@
* @see org.apache.kafka.streams.StreamsConfig
*/
@Supp
chia7712 commented on code in PR #20134:
URL: https://github.com/apache/kafka/pull/20134#discussion_r2218179982
##
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java:
##
@@ -896,12 +896,134 @@ public void testPropsToMap() {
assertValue(Collections.emptyM
LoganZhuZzz opened a new pull request, #20206:
URL: https://github.com/apache/kafka/pull/20206
## Summary
jira: https://issues.apache.org/jira/browse/KAFKA-19517
Ensure `LoadSummary#numRecords` counts all records, including control
batches, to maintain consistency with numBytes.
github-actions[bot] commented on PR #18600:
URL: https://github.com/apache/kafka/pull/18600#issuecomment-3095141386
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the P
github-actions[bot] commented on PR #19468:
URL: https://github.com/apache/kafka/pull/19468#issuecomment-3095141551
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the P
github-actions[bot] commented on PR #18526:
URL: https://github.com/apache/kafka/pull/18526#issuecomment-3095141361
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the P
github-actions[bot] commented on PR #20129:
URL: https://github.com/apache/kafka/pull/20129#issuecomment-3095122617
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #20162:
URL: https://github.com/apache/kafka/pull/20162#issuecomment-3095122544
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
kamalcph commented on PR #20204:
URL: https://github.com/apache/kafka/pull/20204#issuecomment-3095052203
@showuon @FrankYang0529 @chia7712
call for review. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
chia7712 merged PR #20024:
URL: https://github.com/apache/kafka/pull/20024
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache
k-raina commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2217980500
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryUtils.java:
##
@@ -181,13 +182,28 @@ public static boolean
validateRequiredResource
[
https://issues.apache.org/jira/browse/KAFKA-19526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bolin Lin reassigned KAFKA-19526:
-
Assignee: Bolin Lin (was: Chia-Ping Tsai)
> Enable to use DescribeTopicPartitionsRequest with
chia7712 commented on PR #19203:
URL: https://github.com/apache/kafka/pull/19203#issuecomment-3094818576
@CalvinConfluent Do you have free cycles to address @frankvicky's comment?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
[
https://issues.apache.org/jira/browse/KAFKA-19526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008556#comment-18008556
]
Chia-Ping Tsai commented on KAFKA-19526:
we could revisit this jira after KAFKA-
Chia-Ping Tsai created KAFKA-19526:
--
Summary: Enable to use DescribeTopicPartitionsRequest with topic
id
Key: KAFKA-19526
URL: https://issues.apache.org/jira/browse/KAFKA-19526
Project: Kafka
chia7712 commented on code in PR #19914:
URL: https://github.com/apache/kafka/pull/19914#discussion_r2217961135
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -178,6 +178,15 @@ public CommitRequestManager(
*/
@Ove
chia7712 merged PR #20115:
URL: https://github.com/apache/kafka/pull/20115
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache
chia7712 commented on code in PR #19820:
URL: https://github.com/apache/kafka/pull/19820#discussion_r2217941355
##
tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java:
##
@@ -366,6 +378,75 @@ Entry>
sendDeleteShareGroupOffsetsRequest(Stri
majialoong opened a new pull request, #20205:
URL: https://github.com/apache/kafka/pull/20205
Optimize `RemoteLogManager#buildFilteredLeaderEpochMap` .
Use JMH test :
```
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.NANOSECONDS)
@State(Scope.Thread)
public
kamalcph commented on PR #20203:
URL: https://github.com/apache/kafka/pull/20203#issuecomment-3094659367
Opened #20204 to refactor the TBRLMM implementation.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/KAFKA-19148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008542#comment-18008542
]
Calvin Liu edited comment on KAFKA-19148 at 7/20/25 5:18 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-19148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008542#comment-18008542
]
Calvin Liu commented on KAFKA-19148:
[~emanuelmena] The error message is incorrect.
kamalcph opened a new pull request, #20204:
URL: https://github.com/apache/kafka/pull/20204
- Replaces repetitive lock handling logic with
`withReadLockAndEnsureInitialized` to reduce duplication and improve
readability.
- Consolidates initialization logic in `initializeResources` and si
Kamal Chandraprakash created KAFKA-19525:
Summary: Refactor TopicBasedRemoteLogMetadataManager to remove
unused code
Key: KAFKA-19525
URL: https://issues.apache.org/jira/browse/KAFKA-19525
Pro
[
https://issues.apache.org/jira/browse/KAFKA-19525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash reassigned KAFKA-19525:
Assignee: Kamal Chandraprakash
> Refactor TopicBasedRemoteLogMetadataMana
wernerdv commented on code in PR #20115:
URL: https://github.com/apache/kafka/pull/20115#discussion_r2217879722
##
metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetricsTestUtils.java:
##
@@ -64,18 +64,11 @@ enum FakePartitionRegistrationType {
public
wernerdv commented on code in PR #20115:
URL: https://github.com/apache/kafka/pull/20115#discussion_r2217879025
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1697,7 +1692,7 @@ private void registerGeneratePeriodicPerformanceMessage()
{
chia7712 commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2217878159
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryUtils.java:
##
@@ -181,13 +182,28 @@ public static boolean
validateRequiredResourc
chia7712 commented on code in PR #20091:
URL: https://github.com/apache/kafka/pull/20091#discussion_r2217875748
##
tools/src/main/java/org/apache/kafka/tools/ConnectPluginPath.java:
##
@@ -326,11 +322,11 @@ private static Set
enumerateRows(ManifestWorkspace.SourceWorkspace work
chia7712 commented on code in PR #20087:
URL: https://github.com/apache/kafka/pull/20087#discussion_r2217874865
##
storage/src/test/java/org/apache/kafka/tiered/storage/specs/ConsumableSpec.java:
##
@@ -16,33 +16,7 @@
*/
package org.apache.kafka.tiered.storage.specs;
-impor
sjhajharia commented on code in PR #20091:
URL: https://github.com/apache/kafka/pull/20091#discussion_r2217871354
##
tools/src/main/java/org/apache/kafka/tools/ConnectPluginPath.java:
##
@@ -326,11 +322,11 @@ private static Set
enumerateRows(ManifestWorkspace.SourceWorkspace wo
sjhajharia commented on code in PR #19871:
URL: https://github.com/apache/kafka/pull/19871#discussion_r2217865581
##
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java:
##
@@ -187,17 +185,12 @@ public Schema typeSchema(boolean isOptional
chia7712 commented on PR #20195:
URL: https://github.com/apache/kafka/pull/20195#issuecomment-3094606435
I don't think there will be a new release for the 3.7 branch
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
chia7712 commented on code in PR #19871:
URL: https://github.com/apache/kafka/pull/19871#discussion_r2217862544
##
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java:
##
@@ -187,17 +185,12 @@ public Schema typeSchema(boolean isOptional)
chia7712 commented on code in PR #20091:
URL: https://github.com/apache/kafka/pull/20091#discussion_r2217858496
##
tools/src/main/java/org/apache/kafka/tools/ConnectPluginPath.java:
##
@@ -326,11 +322,11 @@ private static Set
enumerateRows(ManifestWorkspace.SourceWorkspace work
chia7712 merged PR #20053:
URL: https://github.com/apache/kafka/pull/20053
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache
chia7712 commented on PR #20053:
URL: https://github.com/apache/kafka/pull/20053#issuecomment-3094595318
the flaky is disabled by #20187
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specif
chia7712 commented on code in PR #20200:
URL: https://github.com/apache/kafka/pull/20200#discussion_r2217850586
##
metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java:
##
@@ -311,9 +311,10 @@ private boolean canElectLastKnownLeader() {
chia7712 commented on code in PR #20053:
URL: https://github.com/apache/kafka/pull/20053#discussion_r2217846826
##
server/src/test/java/org/apache/kafka/server/quota/ClientQuotasRequestTest.java:
##
@@ -0,0 +1,728 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
chia7712 commented on code in PR #20115:
URL: https://github.com/apache/kafka/pull/20115#discussion_r2217843694
##
metadata/src/main/java/org/apache/kafka/metadata/properties/PropertiesUtils.java:
##
@@ -36,7 +36,7 @@ public final class PropertiesUtils {
*
* @param p
kamalcph commented on PR #20203:
URL: https://github.com/apache/kafka/pull/20203#issuecomment-3094562847
When we wait for the SocketServer to be ready before initializing the
TBRLMM, then the user FETCH requests might be served before the initialization,
and IllegalStateException gets throw
kamalcph commented on code in PR #20203:
URL: https://github.com/apache/kafka/pull/20203#discussion_r2217832101
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManager.java:
##
@@ -242,4 +242,18 @@ default Optional
nextSegmentWithTxnInde
kamalcph commented on code in PR #20203:
URL: https://github.com/apache/kafka/pull/20203#discussion_r2217832101
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManager.java:
##
@@ -242,4 +242,18 @@ default Optional
nextSegmentWithTxnInde
kamalcph commented on PR #20201:
URL: https://github.com/apache/kafka/pull/20201#issuecomment-3094500747
@satishd @showuon @frankvicky
Call for review. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/KAFKA-19148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008212#comment-18008212
]
Emanuel Mena edited comment on KAFKA-19148 at 7/20/25 11:34 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008523#comment-18008523
]
Fabrice Bacchella commented on KAFKA-8154:
--
I’m using Kafka 4.0.0 and Conscrypt
[
https://issues.apache.org/jira/browse/KAFKA-19522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008498#comment-18008498
]
TengYao Chi commented on KAFKA-19522:
-
Cherry-pick to 4.1
> LastKnownLeader should
frankvicky commented on PR #20200:
URL: https://github.com/apache/kafka/pull/20200#issuecomment-3094373341
Cherry-pick to 4.1
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
sjhajharia commented on code in PR #20091:
URL: https://github.com/apache/kafka/pull/20091#discussion_r2217710010
##
tools/src/main/java/org/apache/kafka/tools/ConnectPluginPath.java:
##
@@ -326,11 +322,11 @@ private static Set
enumerateRows(ManifestWorkspace.SourceWorkspace wo
[
https://issues.apache.org/jira/browse/KAFKA-19524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanskar Jhajharia reassigned KAFKA-19524:
-
Assignee: Sanskar Jhajharia
> connect-plugin-path crashes with UnsupportedOpera
sjhajharia commented on code in PR #20091:
URL: https://github.com/apache/kafka/pull/20091#discussion_r2217709245
##
tools/src/main/java/org/apache/kafka/tools/ConnectPluginPath.java:
##
@@ -326,11 +322,11 @@ private static Set
enumerateRows(ManifestWorkspace.SourceWorkspace wo
Sanskar Jhajharia created KAFKA-19524:
-
Summary: connect-plugin-path crashes with
UnsupportedOperationException on plugins without ServiceLoader manifests
Key: KAFKA-19524
URL: https://issues.apache.org/jira/b
sjhajharia commented on PR #20180:
URL: https://github.com/apache/kafka/pull/20180#issuecomment-3094366269
Hey @chia7712
A minor PR for review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/KAFKA-19522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TengYao Chi resolved KAFKA-19522.
-
Fix Version/s: 4.2.0
Resolution: Fixed
> LastKnownLeader should only be elected if it is
frankvicky merged PR #20200:
URL: https://github.com/apache/kafka/pull/20200
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apac
[
https://issues.apache.org/jira/browse/KAFKA-19020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008245#comment-18008245
]
Jimmy Wang edited comment on KAFKA-19020 at 7/20/25 8:00 AM:
-
63 matches
Mail list logo
