dajac commented on code in PR #16068:
URL: https://github.com/apache/kafka/pull/16068#discussion_r1614404973
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/GroupSpec.java:
##
@@ -26,9 +26,9 @@
*/
public interface GroupSpec {
/**
- * @r
dajac commented on code in PR #16068:
URL: https://github.com/apache/kafka/pull/16068#discussion_r1614409077
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/GroupSpecImpl.java:
##
@@ -35,6 +37,11 @@ public class GroupSpecImpl implements GroupSpec {
ableegoldman commented on code in PR #16033:
URL: https://github.com/apache/kafka/pull/16033#discussion_r1614410581
##
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java:
##
@@ -58,7 +112,85 @@ public static Map
optimizeRackAwareActiveT
ableegoldman commented on code in PR #16033:
URL: https://github.com/apache/kafka/pull/16033#discussion_r1614411014
##
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java:
##
@@ -74,20 +198,219 @@ public static Map
optimizeRackAwareStand
dajac commented on code in PR #16072:
URL: https://github.com/apache/kafka/pull/16072#discussion_r1614441098
##
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala:
##
@@ -1664,6 +1664,134 @@ class GroupMetadataManagerTest {
assertEquals(0, TestU
[
https://issues.apache.org/jira/browse/KAFKA-16805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849438#comment-17849438
]
黃竣陽 commented on KAFKA-16805:
-
I'm interesting in this issue
> Stop using a ClosureBackedAc
m1a2st opened a new pull request, #16081:
URL: https://github.com/apache/kafka/pull/16081
This issue https://issues.apache.org/jira/browse/KAFKA-16805, I change the
`reports` method to `reports.configure` to avoid use the ClosureBackedAction
interface
--
This is an automated message
mimaison commented on code in PR #16040:
URL: https://github.com/apache/kafka/pull/16040#discussion_r1614511230
##
server/src/main/java/org/apache/kafka/server/config/KafkaServerConfigs.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
[
https://issues.apache.org/jira/browse/KAFKA-16805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849438#comment-17849438
]
黃竣陽 edited comment on KAFKA-16805 at 5/25/24 1:08 PM:
--
I'm interest
FrankYang0529 commented on PR #15908:
URL: https://github.com/apache/kafka/pull/15908#issuecomment-2131274897
> One high-level question:
> I found after this change, we increased the test case numbers from 492 ->
660. And the time for this test suite takes form 1h 19m -> 1h 31m. Do we rea
FrankYang0529 commented on code in PR #15908:
URL: https://github.com/apache/kafka/pull/15908#discussion_r1614679946
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DescribeConsumerGroupTest.java:
##
@@ -141,699 +162,773 @@ public void testPrintVersion(String quorum
TaiJuWu commented on PR #16030:
URL: https://github.com/apache/kafka/pull/16030#issuecomment-2131288594
We can get test report from
tools/build/test-results/test/TEST-org.apache.kafka.tools.TopicCommandIntegrationTest.xml
We find this bottleneck is `setup` so we can merge a small test
mimaison commented on PR #15038:
URL: https://github.com/apache/kafka/pull/15038#issuecomment-2131300855
@linzihao1999 No worries. It's not really urgent but it would be nice to get
it done in the next month or so.
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849461#comment-17849461
]
FTR commented on KAFKA-16687:
-
Handle personal issue, sorry late to reply. Just found more,
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
FTR resolved KAFKA-16687.
-
Resolution: Invalid
> Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0
> ---
jolshan commented on code in PR #16072:
URL: https://github.com/apache/kafka/pull/16072#discussion_r1614738949
##
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala:
##
@@ -1664,6 +1664,134 @@ class GroupMetadataManagerTest {
assertEquals(0, Tes
chia7712 commented on PR #16030:
URL: https://github.com/apache/kafka/pull/16030#issuecomment-2131313203
@TaiJuWu As TopicCommandIntegrationTest is a large test, could you please
try to file multiple PRs to move it to TopicCommandTest with new test infra and
refactor (you described) ?
--
Justine Olshan created KAFKA-16841:
--
Summary: ZKIntegrationTests broken
Key: KAFKA-16841
URL: https://issues.apache.org/jira/browse/KAFKA-16841
Project: Kafka
Issue Type: Task
Re
[
https://issues.apache.org/jira/browse/KAFKA-16841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-16841:
---
Summary: ZKMigratoinIntegrationTests broken (was: ZKIntegrationTests
broken)
> ZKMigratoin
[
https://issues.apache.org/jira/browse/KAFKA-16841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-16841:
---
Summary: ZKMigrationIntegrationTests broken (was:
ZKMigratoinIntegrationTests broken)
> ZK
jolshan commented on PR #16006:
URL: https://github.com/apache/kafka/pull/16006#issuecomment-2131315366
Are we sure the failures are not related? It seems there are consistent
ZKMigrationIntegrationTest failures on trunk since this change. Reverting the
change fixes the issue.
--
This i
[
https://issues.apache.org/jira/browse/KAFKA-16841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849463#comment-17849463
]
Justine Olshan commented on KAFKA-16841:
I am suspicious of https://github.com/a
[
https://issues.apache.org/jira/browse/KAFKA-16841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849464#comment-17849464
]
Justine Olshan commented on KAFKA-16841:
Reverting that commit seems to fix the
jolshan opened a new pull request, #16082:
URL: https://github.com/apache/kafka/pull/16082
This change seems to have broken several ZKMigrationIntegrationTests. I have
filed https://issues.apache.org/jira/browse/KAFKA-16841 but would like to fix
our builds for now.
### Committer Chec
jolshan commented on PR #16006:
URL: https://github.com/apache/kafka/pull/16006#issuecomment-2131316535
https://github.com/apache/kafka/pull/16082 to revert. If folks can find a
fix quickly that also works.
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/KAFKA-16841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849466#comment-17849466
]
Justine Olshan commented on KAFKA-16841:
I opened [https://github.com/apache/kaf
dajac merged PR #15974:
URL: https://github.com/apache/kafka/pull/15974
--
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
[
https://issues.apache.org/jira/browse/KAFKA-16625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-16625.
-
Fix Version/s: 3.8.0
Reviewer: David Jacot
Resolution: Fixed
> Reverse Lookup Pa
dajac commented on code in PR #16072:
URL: https://github.com/apache/kafka/pull/16072#discussion_r1614757426
##
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala:
##
@@ -1664,6 +1664,134 @@ class GroupMetadataManagerTest {
assertEquals(0, TestU
jolshan commented on code in PR #16072:
URL: https://github.com/apache/kafka/pull/16072#discussion_r1614757904
##
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala:
##
@@ -1664,6 +1664,134 @@ class GroupMetadataManagerTest {
assertEquals(0, Tes
dajac commented on code in PR #16072:
URL: https://github.com/apache/kafka/pull/16072#discussion_r1614757426
##
core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala:
##
@@ -1664,6 +1664,134 @@ class GroupMetadataManagerTest {
assertEquals(0, TestU
TaiJuWu commented on PR #16030:
URL: https://github.com/apache/kafka/pull/16030#issuecomment-2131385588
> @TaiJuWu As TopicCommandIntegrationTest is a large test, could you please
try to file multiple PRs to move it to TopicCommandTest with new test infra and
refactor (you described) ?
mjsax merged PR #16076:
URL: https://github.com/apache/kafka/pull/16076
--
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
jolshan commented on PR #16082:
URL: https://github.com/apache/kafka/pull/16082#issuecomment-2131668386
No ZkMigrationIntegrationTest failures. 👍
--
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
jsancio commented on code in PR #15986:
URL: https://github.com/apache/kafka/pull/15986#discussion_r1610641974
##
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala:
##
@@ -1366,6 +1368,26 @@ class KafkaConfigTest {
assertEquals(expectedVoters, addresses)
}
+
[
https://issues.apache.org/jira/browse/KAFKA-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-16824:
---
Description:
For example it is not able to detect at least these mal
jsancio commented on code in PR #15986:
URL: https://github.com/apache/kafka/pull/15986#discussion_r1614958193
##
raft/src/main/java/org/apache/kafka/raft/RequestManager.java:
##
@@ -17,108 +17,196 @@
package org.apache.kafka.raft;
import java.util.ArrayList;
+import java.ut
José Armando García Sancio created KAFKA-16842:
--
Summary: Make sure to validate controller.quorum.bootstrap.server
Key: KAFKA-16842
URL: https://issues.apache.org/jira/browse/KAFKA-16842
P
linzihao1999 opened a new pull request, #14686:
URL: https://github.com/apache/kafka/pull/14686
The tests in ResetConsumerGroupOffsetTest in
core/src/test/scala/unit/kafka/admin/ResetConsumerGroupOffsetTest.scala update
to support KRaft.
### Committer Checklist (excluded from commit
ijuma commented on PR #16051:
URL: https://github.com/apache/kafka/pull/16051#issuecomment-2132080935
I'm ok going with something like this to start with.
--
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
40 matches
Mail list logo
