m1a2st commented on code in PR #19034:
URL: https://github.com/apache/kafka/pull/19034#discussion_r1971614754
##
tests/kafkatest/services/kafka/kafka.py:
##
@@ -1362,7 +1356,7 @@ def alter_message_format(self, topic, msg_format_version,
node=None):
def kafka_acls_cmd_with_
[
https://issues.apache.org/jira/browse/KAFKA-15283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930701#comment-17930701
]
Lianet Magrans commented on KAFKA-15283:
Hi [~isding_l] , not working on it beca
sjhajharia commented on PR #19009:
URL: https://github.com/apache/kafka/pull/19009#issuecomment-2685660580
hey @chia7712
gentle reminder for this PR
Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
[
https://issues.apache.org/jira/browse/KAFKA-18874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18874:
---
Component/s: controller
> KRaft controller does not retry registrati
ijuma merged PR #19033:
URL: https://github.com/apache/kafka/pull/19033
--
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.or
ijuma commented on PR #19033:
URL: https://github.com/apache/kafka/pull/19033#issuecomment-2685752393
Cherry-picked to 4.0 as well.
--
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 co
cmccabe commented on code in PR #18949:
URL: https://github.com/apache/kafka/pull/18949#discussion_r1972230877
##
core/src/main/scala/kafka/raft/RaftManager.scala:
##
@@ -104,6 +104,8 @@ trait RaftManager[T] {
def replicatedLog: ReplicatedLog
def voterNode(id: Int, liste
dongnuo123 opened a new pull request, #19042:
URL: https://github.com/apache/kafka/pull/19042
… must check topic describe (#18989)
This patch filters out the topic describe unauthorized topics from the
ConsumerGroupHeartbeat and ConsumerGroupDescribe response.
In ConsumerGroupH
dongnuo123 commented on code in PR #19042:
URL: https://github.com/apache/kafka/pull/19042#discussion_r1972238070
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -158,29 +160,28 @@ public Builder withGroupConfigManager(Gr
lianetm commented on code in PR #18945:
URL: https://github.com/apache/kafka/pull/18945#discussion_r1971704382
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -165,16 +165,18 @@ public AbstractCoordinator(GroupRebalanceConfig
mumrah commented on PR #19031:
URL: https://github.com/apache/kafka/pull/19031#issuecomment-2686054397
Seems to have reproduced here:
https://github.com/apache/kafka/actions/runs/13550598471/job/37873138268?pr=19031
No activity for a while after
```
Wed, 26 Feb 2025 18:35:41 GMT
Rancho-7 commented on code in PR #19039:
URL: https://github.com/apache/kafka/pull/19039#discussion_r1971674751
##
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java:
##
@@ -450,6 +450,33 @@ public void testConfigProvidersPropsAsParam() {
MockF
Rancho-7 commented on code in PR #19039:
URL: https://github.com/apache/kafka/pull/19039#discussion_r1971671660
##
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java:
##
@@ -450,6 +450,33 @@ public void testConfigProvidersPropsAsParam() {
MockF
Rancho-7 commented on code in PR #19039:
URL: https://github.com/apache/kafka/pull/19039#discussion_r1971676812
##
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java:
##
@@ -450,6 +450,33 @@ public void testConfigProvidersPropsAsParam() {
MockF
Rancho-7 commented on code in PR #19039:
URL: https://github.com/apache/kafka/pull/19039#discussion_r1971676812
##
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java:
##
@@ -450,6 +450,33 @@ public void testConfigProvidersPropsAsParam() {
MockF
mumrah commented on code in PR #18963:
URL: https://github.com/apache/kafka/pull/18963#discussion_r1971693097
##
tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java:
##
@@ -79,7 +79,8 @@ public static void main(String[] args) {
shareConsumer
dongnuo123 commented on code in PR #18989:
URL: https://github.com/apache/kafka/pull/18989#discussion_r1971754326
##
core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala:
##
@@ -561,5 +568,17 @@ abstract class EndToEndAuthorizationTest extends
IntegrationTe
[
https://issues.apache.org/jira/browse/KAFKA-18329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930718#comment-17930718
]
Ismael Juma commented on KAFKA-18329:
-
Why 4.2.0? What's stopping us from doing it n
ijuma commented on code in PR #19034:
URL: https://github.com/apache/kafka/pull/19034#discussion_r1971797966
##
tests/kafkatest/services/kafka/kafka.py:
##
@@ -1362,7 +1356,7 @@ def alter_message_format(self, topic, msg_format_version,
node=None):
def kafka_acls_cmd_with_o
FrankYang0529 opened a new pull request, #19040:
URL: https://github.com/apache/kafka/pull/19040
The `FeatureControlManager` used `MetadataVersion#LATEST_PRODUCTION`
as uninitialized MV. This makes other component may get a stale MV.
In production code, the `FeatureControlManager` set M
lianetm commented on code in PR #18989:
URL: https://github.com/apache/kafka/pull/18989#discussion_r1971805902
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2592,6 +2608,38 @@ class KafkaApis(val requestChannel: RequestChannel,
response.groups.addAll(r
m1a2st commented on code in PR #19034:
URL: https://github.com/apache/kafka/pull/19034#discussion_r1971599561
##
tests/kafkatest/services/kafka/kafka.py:
##
@@ -1362,7 +1356,7 @@ def alter_message_format(self, topic, msg_format_version,
node=None):
def kafka_acls_cmd_with_
frankvicky commented on code in PR #19039:
URL: https://github.com/apache/kafka/pull/19039#discussion_r1971633273
##
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java:
##
@@ -450,6 +450,33 @@ public void testConfigProvidersPropsAsParam() {
Moc
m1a2st commented on code in PR #19038:
URL: https://github.com/apache/kafka/pull/19038#discussion_r1971566712
##
server/src/main/java/org/apache/kafka/server/config/ServerConfigs.java:
##
@@ -52,7 +52,8 @@ public class ServerConfigs {
public static final String BACKGROUND_T
m1a2st commented on code in PR #18299:
URL: https://github.com/apache/kafka/pull/18299#discussion_r1971829502
##
.github/workflows/build.yml:
##
@@ -127,6 +127,9 @@ jobs:
gradle-cache-read-only: ${{ !inputs.is-trunk }}
gradle-cache-write-only: ${{ inputs.is
lucasbru merged PR #18979:
URL: https://github.com/apache/kafka/pull/18979
--
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
ijuma commented on code in PR #19033:
URL: https://github.com/apache/kafka/pull/19033#discussion_r1971831709
##
docs/implementation.html:
##
@@ -103,67 +103,8 @@ 5.3.3 Old Message Format
-Prior to Kafka 0.11, messages were transferred and stored in
message sets. I
[
https://issues.apache.org/jira/browse/KAFKA-18651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-18651:
---
Fix Version/s: 4.1
> Core streams-specific broker configurations
> -
[
https://issues.apache.org/jira/browse/KAFKA-18651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-18651:
---
Fix Version/s: 4.1.0
(was: 4.1)
> Core streams-specific broker config
Rancho-7 opened a new pull request, #19039:
URL: https://github.com/apache/kafka/pull/19039
jira: https://issues.apache.org/jira/browse/KAFKA-18850
`org.apache.kafka.automatic.config.providers = env` is incorrect. According
to the source code, the correct value should be the [class
n
m1a2st commented on code in PR #19025:
URL: https://github.com/apache/kafka/pull/19025#discussion_r1971727446
##
README.md:
##
@@ -75,6 +76,7 @@ Retries are disabled by default, but you can set
maxTestRetryFailures and maxTes
The following example declares -PmaxTestRetries=1 a
m1a2st commented on code in PR #19025:
URL: https://github.com/apache/kafka/pull/19025#discussion_r1971727446
##
README.md:
##
@@ -75,6 +76,7 @@ Retries are disabled by default, but you can set
maxTestRetryFailures and maxTes
The following example declares -PmaxTestRetries=1 a
kevin-wu24 commented on code in PR #18987:
URL: https://github.com/apache/kafka/pull/18987#discussion_r1971722138
##
raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java:
##
@@ -1127,14 +1331,75 @@ private MajorityReachedHighWatermark(Cluster cluster) {
m1a2st commented on code in PR #19025:
URL: https://github.com/apache/kafka/pull/19025#discussion_r1971727446
##
README.md:
##
@@ -75,6 +76,7 @@ Retries are disabled by default, but you can set
maxTestRetryFailures and maxTes
The following example declares -PmaxTestRetries=1 a
Eslam Mohamed created KAFKA-18873:
-
Summary: Incorrect error message for
max.in.flight.requests.per.connection when using transactional producer.
Key: KAFKA-18873
URL: https://issues.apache.org/jira/browse/KAFKA-1
[
https://issues.apache.org/jira/browse/KAFKA-18872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930717#comment-17930717
]
Ismael Juma commented on KAFKA-18872:
-
Given that this is exercising the log layer,
m1a2st commented on code in PR #19020:
URL: https://github.com/apache/kafka/pull/19020#discussion_r1971884683
##
clients/src/test/java/org/apache/kafka/common/errors/TransactionExceptionHierarchyTest.java:
##
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Software Foundation (A
[
https://issues.apache.org/jira/browse/KAFKA-18877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930871#comment-17930871
]
David Arthur commented on KAFKA-18877:
--
I think the most likely unsafe access is re
clarkwtc commented on code in PR #19016:
URL: https://github.com/apache/kafka/pull/19016#discussion_r1972555921
##
server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java:
##
@@ -78,6 +78,7 @@ public final class ServerTopicConfigSynonyms {
clarkwtc commented on code in PR #19016:
URL: https://github.com/apache/kafka/pull/19016#discussion_r1972555921
##
server-common/src/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java:
##
@@ -78,6 +78,7 @@ public final class ServerTopicConfigSynonyms {
apoorvmittal10 opened a new pull request, #19045:
URL: https://github.com/apache/kafka/pull/19045
The PR implements the SharePartitionMetrics as defined in KIP-1103, with one
change. The metric `FetchLockRatio` is defined as `Meter` in KIP but is
implemented as `HIstogram`. There was a disc
[
https://issues.apache.org/jira/browse/KAFKA-18863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-18863.
-
Fix Version/s: 4.1.0
Resolution: Fixed
> Runtime additions for connector multiversioning.
Apoorv Mittal created KAFKA-18878:
-
Summary: Implement share session cache metrics for share fetch
Key: KAFKA-18878
URL: https://issues.apache.org/jira/browse/KAFKA-18878
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-18878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-18878:
--
Summary: Implement ShareSessionCache and DelayedShareFetchMetrics metrics
for share fetch (wa
gharris1727 merged PR #17743:
URL: https://github.com/apache/kafka/pull/17743
--
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.apa
ableegoldman commented on code in PR #17614:
URL: https://github.com/apache/kafka/pull/17614#discussion_r1972542173
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -275,6 +284,24 @@ public int memberEpoch() {
re
[
https://issues.apache.org/jira/browse/KAFKA-18877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930883#comment-17930883
]
TengYao Chi commented on KAFKA-18877:
-
Hi [~chia7712]
If you are not start working
[
https://issues.apache.org/jira/browse/KAFKA-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930891#comment-17930891
]
Kirk True commented on KAFKA-15636:
---
Can we do both :) Process the first fetch and mak
chia7712 commented on code in PR #18726:
URL: https://github.com/apache/kafka/pull/18726#discussion_r1972645207
##
clients/src/main/resources/common/message/FetchResponse.json:
##
@@ -106,7 +106,7 @@
]},
{ "name": "PreferredReadReplica", "type": "int32", "versi
[
https://issues.apache.org/jira/browse/KAFKA-18876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-18876:
---
Fix Version/s: 4.0.0
> 4.0 documentation improvement
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-17037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930895#comment-17930895
]
TaiJuWu commented on KAFKA-17037:
-
Hi [~isding_l] , this ticket was finished for a long
clarkwtc opened a new pull request, #19046:
URL: https://github.com/apache/kafka/pull/19046
Migrate RebootstrapTest to new test infra and remove the old Scala test.
The test results
https://github.com/user-attachments/assets/35812c96-13f7-41f8-829d-40947f768646";
/>
--
[
https://issues.apache.org/jira/browse/KAFKA-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-18850:
---
Fix Version/s: 4.0.0
> Fix the docs of org.apache.kafka.automatic.config.providers
> ---
[
https://issues.apache.org/jira/browse/KAFKA-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-18849:
---
Fix Version/s: 4.0.0
> add "strict min ISR" to the docs of "min.insync.replicas"
> -
[
https://issues.apache.org/jira/browse/KAFKA-18868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-18868:
---
Fix Version/s: 4.0.0
> add the "default value" explanation to the docs of
> num.replica.alt
[
https://issues.apache.org/jira/browse/KAFKA-18869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-18869:
---
Fix Version/s: 4.0.0
> add remote storage threads to "Updating Thread Configs" section
> ---
LoganZhuZzz commented on code in PR #19038:
URL: https://github.com/apache/kafka/pull/19038#discussion_r1972652456
##
server/src/main/java/org/apache/kafka/server/config/ServerConfigs.java:
##
@@ -52,7 +52,8 @@ public class ServerConfigs {
public static final String BACKGRO
[
https://issues.apache.org/jira/browse/KAFKA-17037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930896#comment-17930896
]
Lan Ding commented on KAFKA-17037:
--
Hi [~taijuwu] , If this ticket is still open, may
[ https://issues.apache.org/jira/browse/KAFKA-17037 ]
Lan Ding deleted comment on KAFKA-17037:
--
was (Author: JIRAUSER30):
Hi [~taijuwu] , If this ticket is still open, may I take it over?
> KIP-919 supports for `describeClientQuotas` and `alt
[
https://issues.apache.org/jira/browse/KAFKA-18870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TaiJuWu reassigned KAFKA-18870:
---
Assignee: TaiJuWu
> implement describeDelegationToken for controller
>
[
https://issues.apache.org/jira/browse/KAFKA-17651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930897#comment-17930897
]
Lan Ding commented on KAFKA-17651:
--
Hi [~frankvicky], If this ticket is still open, ma
junrao commented on code in PR #18726:
URL: https://github.com/apache/kafka/pull/18726#discussion_r1972659486
##
clients/src/main/resources/common/message/FetchResponse.json:
##
@@ -106,7 +106,7 @@
]},
{ "name": "PreferredReadReplica", "type": "int32", "version
chia7712 commented on code in PR #19039:
URL: https://github.com/apache/kafka/pull/19039#discussion_r1972658599
##
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java:
##
@@ -450,6 +450,33 @@ public void testConfigProvidersPropsAsParam() {
MockF
[
https://issues.apache.org/jira/browse/KAFKA-18870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930898#comment-17930898
]
Szu-Yung Wang commented on KAFKA-18870:
---
Hi, may I take this?
> implement describ
FrankYang0529 commented on PR #18997:
URL: https://github.com/apache/kafka/pull/18997#issuecomment-2686577937
@junrao updated PR description. Also, added reviewers to it. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/KAFKA-17039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930900#comment-17930900
]
Lan Ding commented on KAFKA-17039:
--
Hi [~frankvicky], If this ticket is still open, ma
[
https://issues.apache.org/jira/browse/KAFKA-17037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930892#comment-17930892
]
Lan Ding commented on KAFKA-17037:
--
Hi [~taijuwu], are you still working on this? I wou
xijiu commented on code in PR #18299:
URL: https://github.com/apache/kafka/pull/18299#discussion_r1972668711
##
.github/workflows/build.yml:
##
@@ -127,6 +127,9 @@ jobs:
gradle-cache-read-only: ${{ !inputs.is-trunk }}
gradle-cache-write-only: ${{ inputs.is-
[
https://issues.apache.org/jira/browse/KAFKA-17039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930903#comment-17930903
]
TengYao Chi commented on KAFKA-17039:
-
Hi [~isding_l]
Thanks for the interest.
Ho
ijuma commented on code in PR #18726:
URL: https://github.com/apache/kafka/pull/18726#discussion_r1972672957
##
clients/src/main/resources/common/message/FetchResponse.json:
##
@@ -106,7 +106,7 @@
]},
{ "name": "PreferredReadReplica", "type": "int32", "versions
[
https://issues.apache.org/jira/browse/KAFKA-15283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lan Ding reassigned KAFKA-15283:
Assignee: Lan Ding (was: Lianet Magrans)
> Client support for OffsetFetch and OffsetCommit with
[
https://issues.apache.org/jira/browse/KAFKA-18877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-18877:
--
Assignee: TengYao Chi (was: Chia-Ping Tsai)
> an mechanism to find cases where we ac
chia7712 commented on code in PR #18726:
URL: https://github.com/apache/kafka/pull/18726#discussion_r1972681634
##
clients/src/main/resources/common/message/FetchResponse.json:
##
@@ -106,7 +106,7 @@
]},
{ "name": "PreferredReadReplica", "type": "int32", "versi
ijuma commented on PR #19016:
URL: https://github.com/apache/kafka/pull/19016#issuecomment-2686608878
I pushed a very minor tweak.
--
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 com
kirktrue commented on code in PR #17340:
URL: https://github.com/apache/kafka/pull/17340#discussion_r1972681856
##
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java:
##
@@ -148,6 +175,7 @@ KafkaProducer
createKafkaProducer(Properties props) {
Callback cb;
chia7712 commented on code in PR #19039:
URL: https://github.com/apache/kafka/pull/19039#discussion_r1972690127
##
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java:
##
@@ -450,6 +451,32 @@ public void testConfigProvidersPropsAsParam() {
MockF
chia7712 merged PR #19037:
URL: https://github.com/apache/kafka/pull/19037
--
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 #19037:
URL: https://github.com/apache/kafka/pull/19037#issuecomment-2686638814
cherry-pick to 4.0
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-18869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-18869.
Resolution: Fixed
trunk:
[https://github.com/apache/kafka/commit/8bbca913efe260ba59c82480
[
https://issues.apache.org/jira/browse/KAFKA-18875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TaiJuWu resolved KAFKA-18875.
-
Resolution: Duplicate
> KRaft controller does not retry registration if the first attempt times out
> --
chia7712 commented on code in PR #19027:
URL: https://github.com/apache/kafka/pull/19027#discussion_r1972693467
##
core/src/main/scala/kafka/server/ControllerApis.scala:
##
@@ -642,9 +642,11 @@ class ControllerApis(
def createResponseCallback(requestThrottleMs: Int,
[
https://issues.apache.org/jira/browse/KAFKA-17651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TengYao Chi updated KAFKA-17651:
Description: Currently there is no implementation for
`describeUserScramCredentials` (was: Curren
[
https://issues.apache.org/jira/browse/KAFKA-17651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930930#comment-17930930
]
TengYao Chi commented on KAFKA-17651:
-
Hi [~isding_l]
Thanks for offering to help,
frankvicky commented on code in PR #17614:
URL: https://github.com/apache/kafka/pull/17614#discussion_r1972757524
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java:
##
@@ -1151,31 +1153,28 @@ protected void handlePollTimeoutExpiry() {
k-raina commented on code in PR #19020:
URL: https://github.com/apache/kafka/pull/19020#discussion_r1971936154
##
clients/src/test/java/org/apache/kafka/common/errors/TransactionExceptionHierarchyTest.java:
##
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Software Foundation (
Daniel Fonai created KAFKA-18875:
Summary: KRaft controller does not retry registration if the first
attempt times out
Key: KAFKA-18875
URL: https://issues.apache.org/jira/browse/KAFKA-18875
Project:
[
https://issues.apache.org/jira/browse/KAFKA-18874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930751#comment-17930751
]
Ismael Juma commented on KAFKA-18874:
-
Thanks for the report. Can you specify the ve
lianetm merged PR #18989:
URL: https://github.com/apache/kafka/pull/18989
--
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.
mumrah commented on PR #18997:
URL: https://github.com/apache/kafka/pull/18997#issuecomment-2685820634
Regarding:
https://github.com/user-attachments/assets/096cf482-4701-4219-a8eb-c5613adfb390";
/>
This was added in #18985 as part of the merge queue effort. It is not yet
require
junrao commented on PR #18997:
URL: https://github.com/apache/kafka/pull/18997#issuecomment-2685839532
@FrankYang0529 : Thanks for the updated description. Just a minor comment.
This makes finalized features may be stale when processing registerBroker
event. => This may make finaliz
[
https://issues.apache.org/jira/browse/KAFKA-18873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-18873:
--
Component/s: producer
> Incorrect error message for max.in.flight.requests.per.connection when using
Jun Rao created KAFKA-18876:
---
Summary: 4.0 documentation improvement
Key: KAFKA-18876
URL: https://issues.apache.org/jira/browse/KAFKA-18876
Project: Kafka
Issue Type: Improvement
Affects Versi
mumrah commented on code in PR #19031:
URL: https://github.com/apache/kafka/pull/19031#discussion_r1972112034
##
build.gradle:
##
@@ -54,7 +54,7 @@ ext {
buildVersionFileName = "kafka-version.properties"
defaultMaxHeapSize = "2g"
- defaultJvmArgs = ["-Xss4m", "-XX:+UseP
[
https://issues.apache.org/jira/browse/KAFKA-16092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield updated KAFKA-16092:
-
Fix Version/s: (was: 4.1.0)
> Queues for Kafka
>
>
>
Daniel Fonai created KAFKA-18874:
Summary: KRaft controller does not retry registration if the first
attempt times out
Key: KAFKA-18874
URL: https://issues.apache.org/jira/browse/KAFKA-18874
Project:
mumrah commented on PR #19031:
URL: https://github.com/apache/kafka/pull/19031#issuecomment-2685589737
It looks like the UserQuotaTest is the likely culprit.
From https://github.com/apache/kafka/actions/runs/13523225366/job/37791507296
```
Gradle Test Run :core:test > Gradle Tes
k-raina commented on code in PR #19020:
URL: https://github.com/apache/kafka/pull/19020#discussion_r1971934155
##
clients/src/test/java/org/apache/kafka/common/errors/TransactionExceptionHierarchyTest.java:
##
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Software Foundation (
FrankYang0529 commented on PR #18801:
URL: https://github.com/apache/kafka/pull/18801#issuecomment-2685571786
@mumrah I update benchmark to PR description. The result is a little
different from yours. The difference between trunk and branch results on my
laptop is close, so I think the resu
k-raina commented on code in PR #19020:
URL: https://github.com/apache/kafka/pull/19020#discussion_r1971934155
##
clients/src/test/java/org/apache/kafka/common/errors/TransactionExceptionHierarchyTest.java:
##
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Software Foundation (
[
https://issues.apache.org/jira/browse/KAFKA-18723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18723:
---
Fix Version/s: 4.0.1
> KRaft must handle corrupted records in the fe
1 - 100 of 179 matches
Mail list logo
