m1a2st commented on code in PR #15808:
URL: https://github.com/apache/kafka/pull/15808#discussion_r1584248006
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -321,16 +322,16 @@ class RemoteIndexCacheTest {
// Give the thread cleaner thread som
chia7712 commented on code in PR #15819:
URL: https://github.com/apache/kafka/pull/15819#discussion_r1584226418
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1469,6 +1469,10 @@ private Thread shutdownHelper(final boolean error, final
long timeoutMs
chia7712 commented on code in PR #15808:
URL: https://github.com/apache/kafka/pull/15808#discussion_r1584251393
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -321,16 +322,16 @@ class RemoteIndexCacheTest {
// Give the thread cleaner thread s
chia7712 commented on PR #15055:
URL: https://github.com/apache/kafka/pull/15055#issuecomment-2084584466
any update here?
--
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
[
https://issues.apache.org/jira/browse/KAFKA-10859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-10859.
Resolution: Duplicate
fixed by
https://github.com/apache/kafka/commit/3dacdc5694da5db2835
raminqaf commented on PR #15601:
URL: https://github.com/apache/kafka/pull/15601#issuecomment-2084636567
@gharris1727 Thanks for the positive feedback! I am happy that you like the
changes! I addressed all your nit reviews and refactored the logic of the
non-final boolean variables (i.e., `
lucasbru commented on PR #15723:
URL: https://github.com/apache/kafka/pull/15723#issuecomment-2084640215
@philipnee Since the unresolved conversation is only around an internal
method name, I'm merging this. Feel free to ask for a follow-up PR
--
This is an automated message from the Apac
lucasbru merged PR #15723:
URL: https://github.com/apache/kafka/pull/15723
--
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
AyoubOm commented on PR #15615:
URL: https://github.com/apache/kafka/pull/15615#issuecomment-2084651380
> @AyoubOm -- Thanks for the PR! I did not forget about it. Just did not
find time yet to take a look. Still plan to get this merged for 3.8 release...
Sorry for the long wait, and thanks
[
https://issues.apache.org/jira/browse/KAFKA-16644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842285#comment-17842285
]
Ayoub Omari commented on KAFKA-16644:
-
Hi [~mjsax], I think this is the same issue r
chia7712 commented on code in PR #15715:
URL: https://github.com/apache/kafka/pull/15715#discussion_r1584322426
##
core/src/test/java/kafka/test/junit/ClusterTestExtensions.java:
##
@@ -196,16 +197,35 @@ private void processClusterTest(ExtensionContext context,
ClusterTest anno
Mickael Maison created KAFKA-16645:
--
Summary: CVEs in 3.7.0 docker image
Key: KAFKA-16645
URL: https://issues.apache.org/jira/browse/KAFKA-16645
Project: Kafka
Issue Type: Task
Affects V
[
https://issues.apache.org/jira/browse/KAFKA-16645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-16645:
---
Description:
Our [Docker Image CVE
Scanner|https://github.com/apache/kafka/actions/runs/
Mickael Maison created KAFKA-16646:
--
Summary: Consider only running the CVE scanner action on
apache/kafka and not in forks
Key: KAFKA-16646
URL: https://issues.apache.org/jira/browse/KAFKA-16646
Pro
[
https://issues.apache.org/jira/browse/KAFKA-16382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842293#comment-17842293
]
Stanislav Spiridonov commented on KAFKA-16382:
--
Any updates/estimations on
Chia-Ping Tsai created KAFKA-16647:
--
Summary: Remove setMetadataDirectory from BrokerNode/ControllerNode
Key: KAFKA-16647
URL: https://issues.apache.org/jira/browse/KAFKA-16647
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vedarth Sharma reassigned KAFKA-16646:
--
Assignee: Vedarth Sharma
> Consider only running the CVE scanner action on apache/kaf
[
https://issues.apache.org/jira/browse/KAFKA-16646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842297#comment-17842297
]
Vedarth Sharma commented on KAFKA-16646:
Created a fix PR https://github.com/apa
[
https://issues.apache.org/jira/browse/KAFKA-16647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842298#comment-17842298
]
Chia-Ping Tsai commented on KAFKA-16647:
btw, this jira can remove the duplicate
FrankYang0529 commented on code in PR #15745:
URL: https://github.com/apache/kafka/pull/15745#discussion_r1584379526
##
core/src/test/java/kafka/test/junit/ClusterTestExtensions.java:
##
@@ -162,32 +162,39 @@ private void processClusterTest(ExtensionContext context,
ClusterTest
nizhikov commented on PR #15645:
URL: https://github.com/apache/kafka/pull/15645#issuecomment-2084760582
@chia7712 Thank you for the review and merge!
Will prepare next test of ConfigCommand for review shortly.
--
This is an automated message from the Apache Git Service.
To respond to
chia7712 commented on code in PR #14716:
URL: https://github.com/apache/kafka/pull/14716#discussion_r1584442796
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java:
##
@@ -411,25 +394,32 @@ public void seek(final TopicPartition partition, fi
chia7712 commented on PR #15381:
URL: https://github.com/apache/kafka/pull/15381#issuecomment-2084846862
@mukkachaitanya Could you please fix the conflicts?
--
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
[
https://issues.apache.org/jira/browse/KAFKA-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842319#comment-17842319
]
PoAn Yang commented on KAFKA-16506:
---
Yeah, if version 2.8 commands are only in folder
mukkachaitanya commented on PR #15381:
URL: https://github.com/apache/kafka/pull/15381#issuecomment-2084860037
This can be closed. @hgeraldino has closed this ticket via other PRs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
cadonna commented on PR #15640:
URL: https://github.com/apache/kafka/pull/15640#issuecomment-2084906500
> > Here I have a comment, I could not put at the right location in the code:
> > On line 1362, in `commitSync()` the consumer waits on the `commitFuture`
with a timer. I think, it shou
nizhikov opened a new pull request, #15832:
URL: https://github.com/apache/kafka/pull/15832
This is second part of https://github.com/apache/kafka/pull/15417
refactoring.
PR intention - split big PR in parts to simplify review.
PR contains UserScramCredentialsCommandTest rewritten in j
nizhikov commented on PR #15832:
URL: https://github.com/apache/kafka/pull/15832#issuecomment-2084909110
Hello @chia7712
Can you, please, take a look?
--
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 t
sanghyeok An created KAFKA-16648:
Summary: Question: KIP-848 and KafkaTestKit.java
Key: KAFKA-16648
URL: https://issues.apache.org/jira/browse/KAFKA-16648
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-16223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842328#comment-17842328
]
Chia-Ping Tsai commented on KAFKA-16223:
It seems `KafkaConfigBackingStoreMockit
[
https://issues.apache.org/jira/browse/KAFKA-16648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sanghyeok An updated KAFKA-16648:
-
Description:
Hi, Kafka Team.
I am writing test code for the new rebalancing protocol proposed in
[
https://issues.apache.org/jira/browse/KAFKA-16223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842328#comment-17842328
]
Chia-Ping Tsai edited comment on KAFKA-16223 at 4/30/24 10:29 AM:
chia7712 closed pull request #15381: KAFKA-16223: Migrate
KafkaConfigBackingStoreTest to Mockito
URL: https://github.com/apache/kafka/pull/15381
--
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 s
[
https://issues.apache.org/jira/browse/KAFKA-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842330#comment-17842330
]
Chia-Ping Tsai commented on KAFKA-16506:
[~yangpoan] thanks for the check. pleas
chia7712 commented on code in PR #15832:
URL: https://github.com/apache/kafka/pull/15832#discussion_r1584553620
##
core/src/test/java/kafka/admin/UserScramCredentialsCommandTest.java:
##
@@ -0,0 +1,178 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
nizhikov commented on code in PR #15832:
URL: https://github.com/apache/kafka/pull/15832#discussion_r1584629877
##
core/src/test/java/kafka/admin/UserScramCredentialsCommandTest.java:
##
@@ -0,0 +1,178 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
[
https://issues.apache.org/jira/browse/KAFKA-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang resolved KAFKA-16506.
---
Resolution: Not A Problem
Compare commands between 2.8 and trunk brand in folders
core/src/main/sca
[
https://issues.apache.org/jira/browse/KAFKA-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842340#comment-17842340
]
PoAn Yang edited comment on KAFKA-16506 at 4/30/24 11:44 AM:
-
FrankYang0529 commented on code in PR #15773:
URL: https://github.com/apache/kafka/pull/15773#discussion_r1584662969
##
server-common/src/main/java/org/apache/kafka/server/config/ServerLogConfigs.java:
##
@@ -86,7 +86,7 @@ public class ServerLogConfigs {
public static fin
FrankYang0529 commented on code in PR #15715:
URL: https://github.com/apache/kafka/pull/15715#discussion_r1584677103
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -172,14 +179,16 @@ public boolean equals(Object object) {
&& Objects.equals(adminClien
brandboat commented on code in PR #15715:
URL: https://github.com/apache/kafka/pull/15715#discussion_r1584685682
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -172,14 +179,16 @@ public boolean equals(Object object) {
&& Objects.equals(adminClientPro
[
https://issues.apache.org/jira/browse/KAFKA-16513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Siddharth Yagnik reassigned KAFKA-16513:
Assignee: Siddharth Yagnik
> Allow WriteTxnMarkers API with Alter Cluster Permiss
nizhikov commented on code in PR #15832:
URL: https://github.com/apache/kafka/pull/15832#discussion_r1584714610
##
core/src/test/java/kafka/admin/UserScramCredentialsCommandTest.java:
##
@@ -0,0 +1,178 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
nizhikov commented on PR #15832:
URL: https://github.com/apache/kafka/pull/15832#issuecomment-2085194654
@soarez Thanks for the valuable feedback. I create java version of
waitUntilTrue method and used it in test. Please, take a look.
--
This is an automated message from the Apache Git Se
chia7712 commented on code in PR #15832:
URL: https://github.com/apache/kafka/pull/15832#discussion_r1584811761
##
core/src/test/java/kafka/admin/UserScramCredentialsCommandTest.java:
##
@@ -0,0 +1,184 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
lianetm commented on code in PR #15766:
URL: https://github.com/apache/kafka/pull/15766#discussion_r1584853415
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupExecutor.java:
##
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
riedelmax commented on PR #15727:
URL: https://github.com/apache/kafka/pull/15727#issuecomment-2085407284
@dajac
part 4/4 would be to handle IncludeAuthorizedOperations in the request
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
lianetm commented on code in PR #15766:
URL: https://github.com/apache/kafka/pull/15766#discussion_r1584897939
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteConsumerGroupsTest.java:
##
@@ -17,279 +17,332 @@
package org.apache.kafka.tools.consumer.group;
lianetm commented on code in PR #15766:
URL: https://github.com/apache/kafka/pull/15766#discussion_r1584897939
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteConsumerGroupsTest.java:
##
@@ -17,279 +17,332 @@
package org.apache.kafka.tools.consumer.group;
lianetm commented on code in PR #15766:
URL: https://github.com/apache/kafka/pull/15766#discussion_r1584902357
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteConsumerGroupsTest.java:
##
@@ -17,279 +17,332 @@
package org.apache.kafka.tools.consumer.group;
lianetm commented on code in PR #15766:
URL: https://github.com/apache/kafka/pull/15766#discussion_r1584929720
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteConsumerGroupsTest.java:
##
@@ -17,279 +17,332 @@
package org.apache.kafka.tools.consumer.group;
[
https://issues.apache.org/jira/browse/KAFKA-16604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842412#comment-17842412
]
Chris Egerton commented on KAFKA-16604:
---
We don't necessarily have to deprecate an
nizhikov commented on code in PR #15832:
URL: https://github.com/apache/kafka/pull/15832#discussion_r1584946619
##
core/src/test/java/kafka/admin/UserScramCredentialsCommandTest.java:
##
@@ -0,0 +1,184 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
nizhikov commented on PR #15832:
URL: https://github.com/apache/kafka/pull/15832#issuecomment-2085538452
@chia7712 All your comments resolved. Please, take a look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
nizhikov commented on code in PR #15832:
URL: https://github.com/apache/kafka/pull/15832#discussion_r1584953273
##
core/src/test/java/kafka/admin/UserScramCredentialsCommandTest.java:
##
@@ -0,0 +1,178 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
[
https://issues.apache.org/jira/browse/KAFKA-16644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842417#comment-17842417
]
Matthias J. Sax commented on KAFKA-16644:
-
Thanks for the pointer. I did not hav
[
https://issues.apache.org/jira/browse/KAFKA-16645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16645:
Fix Version/s: 3.8.0
3.7.1
> CVEs in 3.7.0 docker image
> -
[
https://issues.apache.org/jira/browse/KAFKA-16645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16645:
Priority: Blocker (was: Major)
> CVEs in 3.7.0 docker image
> --
[
https://issues.apache.org/jira/browse/KAFKA-16645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842419#comment-17842419
]
Matthias J. Sax commented on KAFKA-16645:
-
I believe fixing these CVEs should be
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1585005659
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaper.java:
##
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache Software Fo
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1585003046
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaper.java:
##
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache Software Fo
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1585003046
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaper.java:
##
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache Software Fo
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1585004533
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableEventReaper.java:
##
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache Software Fo
[
https://issues.apache.org/jira/browse/KAFKA-16382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842423#comment-17842423
]
Matthias J. Sax commented on KAFKA-16382:
-
Not yet from our side... Working on o
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1585035057
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1853,6 +1824,40 @@ private void subscribeInternal(Collection
topic
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1585083395
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1892,13 +1897,13 @@ private void subscribeInternal(Collection
topi
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1585091606
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1892,13 +1897,13 @@ private void subscribeInternal(Collection
topi
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1585035057
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1853,6 +1824,40 @@ private void subscribeInternal(Collection
topic
dajac merged PR #15818:
URL: https://github.com/apache/kafka/pull/15818
--
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
lianetm commented on code in PR #15640:
URL: https://github.com/apache/kafka/pull/15640#discussion_r1585152310
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1892,13 +1897,13 @@ private void subscribeInternal(Collection
topi
philipnee commented on PR #15723:
URL: https://github.com/apache/kafka/pull/15723#issuecomment-2085841809
Hey sorry for the delay, the changes look good to me.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
dajac commented on code in PR #15785:
URL: https://github.com/apache/kafka/pull/15785#discussion_r1585155736
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -966,6 +979,55 @@ private static void maybeUpdateSubscribedTopicN
rreddy-22 commented on code in PR #15785:
URL: https://github.com/apache/kafka/pull/15785#discussion_r1585158392
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1307,13 +1307,14 @@ private
CoordinatorResult consumerGr
dajac commented on PR #15798:
URL: https://github.com/apache/kafka/pull/15798#issuecomment-2085866313
@dongnuo123 Be aware of https://github.com/apache/kafka/pull/15785. The PR
changes code that you have refactored or reused in this one. We will need to
adapt when we merge it.
--
This is
rreddy-22 commented on code in PR #15785:
URL: https://github.com/apache/kafka/pull/15785#discussion_r1585160959
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1307,13 +1307,14 @@ private
CoordinatorResult consumerGr
brandboat opened a new pull request, #15833:
URL: https://github.com/apache/kafka/pull/15833
related to https://issues.apache.org/jira/browse/KAFKA-16647
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and
C0urante commented on PR #14309:
URL: https://github.com/apache/kafka/pull/14309#issuecomment-2085912341
@gharris1727 I've resolved the merge conflicts again; can you please take a
look when you get a chance?
--
This is an automated message from the Apache Git Service.
To respond to the m
chiacyu commented on code in PR #15823:
URL: https://github.com/apache/kafka/pull/15823#discussion_r1585188342
##
clients/src/main/java/org/apache/kafka/common/utils/Utils.java:
##
@@ -584,27 +584,6 @@ public static String formatBytes(long bytes) {
}
}
-/**
-
kirktrue commented on PR #15723:
URL: https://github.com/apache/kafka/pull/15723#issuecomment-2086027819
Thanks everyone for the reviews and @lucasbru for the merge!
--
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-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842453#comment-17842453
]
Kirk True commented on KAFKA-16623:
---
If I add the following code to {{test_fencing_sta
[
https://issues.apache.org/jira/browse/KAFKA-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16623:
--
Description:
When running system tests for the KafkaAsyncConsumer, we occasionally see this
warning:
[
https://issues.apache.org/jira/browse/KAFKA-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16623:
--
Description:
When running system tests for the KafkaAsyncConsumer, we occasionally see this
warning:
kirktrue closed pull request #14950: KAFKA-16000: Migrate
MembershipManagerImplTest away from ConsumerTestBuilder
URL: https://github.com/apache/kafka/pull/14950
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
Alexander-Aghili closed pull request #15055: KAFKA-16027: MINOR Refactor
MetadataTest#testUpdatePartitionLeadership
URL: https://github.com/apache/kafka/pull/15055
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
Alexander-Aghili commented on PR #15055:
URL: https://github.com/apache/kafka/pull/15055#issuecomment-2086139400
Okay I messed up the git a little here (still have much to learn), the
current trunk does exist on my Kafka-16027 branch but I had to redo it force
push which led to auto-closing
[
https://issues.apache.org/jira/browse/KAFKA-9401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gaurav Narula reassigned KAFKA-9401:
Assignee: Gaurav Narula
> High lock contention for kafka.server.FetchManager.newContext
>
jeffkbkim opened a new pull request, #15835:
URL: https://github.com/apache/kafka/pull/15835
This PR fixes the thread idle ratio. We take a similar approach to the kafka
request handler idle ratio:
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/KafkaRequestHandl
jeffkbkim commented on code in PR #15835:
URL: https://github.com/apache/kafka/pull/15835#discussion_r1585255667
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/MultiThreadedEventProcessorTest.java:
##
@@ -461,26 +459,30 @@ public void testMetrics()
[
https://issues.apache.org/jira/browse/KAFKA-16558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16558:
--
Priority: Minor (was: Major)
> Implement HeartbeatRequestState.toStringBase()
> -
[
https://issues.apache.org/jira/browse/KAFKA-16557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16557:
--
Priority: Minor (was: Major)
> Fix OffsetFetchRequestState.toString()
> -
[
https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842470#comment-17842470
]
Lianet Magrans commented on KAFKA-16637:
Hey [~chickenchickenlove], just to rule
[
https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842470#comment-17842470
]
Lianet Magrans edited comment on KAFKA-16637 at 4/30/24 6:10 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842470#comment-17842470
]
Lianet Magrans edited comment on KAFKA-16637 at 4/30/24 6:10 PM:
-
gaurav-narula opened a new pull request, #15836:
URL: https://github.com/apache/kafka/pull/15836
KIP-227 introduced in-memory caching of FetchSessions. Brokers with a large
number of Fetch requests suffer from contention on trying to acquire a lock on
FetchSessionCache.
This change a
chia7712 commented on code in PR #15766:
URL: https://github.com/apache/kafka/pull/15766#discussion_r1585308784
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteConsumerGroupsTest.java:
##
@@ -17,279 +17,332 @@
package org.apache.kafka.tools.consumer.group;
[
https://issues.apache.org/jira/browse/KAFKA-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16110:
--
Priority: Major (was: Blocker)
> Implement consumer performance tests
> -
gaurav-narula commented on PR #15836:
URL: https://github.com/apache/kafka/pull/15836#issuecomment-2086478984
The following images show lock profiles collected using async-profiler
before and after this change with numCacheShards = numIoThreads = 64 and
demonstrates significant reduction in
gharris1727 commented on code in PR #14309:
URL: https://github.com/apache/kafka/pull/14309#discussion_r1585294415
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java:
##
@@ -655,27 +811,38 @@ private static ConfigInfos validateClientOverrides(S
[
https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16290:
--
Priority: Major (was: Critical)
> Investigate propagating subscription state updates via queues
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-16110:
---
Summary: Document and publicize performance test results for
AsyncKafkaConsumer (was: Implement con
1 - 100 of 160 matches
Mail list logo
