dajac commented on code in PR #17750:
URL: https://github.com/apache/kafka/pull/17750#discussion_r1839658824
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/UnionSet.java:
##
@@ -0,0 +1,212 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897827#comment-17897827
]
Asker commented on KAFKA-17232:
---
[~frankvicky] [~gharris1727]
Hello,
I believe we're exper
KTKTK-HZ closed pull request #16950: KAFKA-17053: Restructure build.gradle to
configure publishing last
URL: https://github.com/apache/kafka/pull/16950
--
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
adixitconfluent commented on code in PR #17739:
URL: https://github.com/apache/kafka/pull/17739#discussion_r1839527959
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -90,39 +90,50 @@ public void onExpiration() {
*/
@Override
public void on
[
https://issues.apache.org/jira/browse/KAFKA-17998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash reassigned KAFKA-17998:
Assignee: Kamal Chandraprakash
> Fix flaky OffloadAndTxnConsumeFromLeader
FrankYang0529 opened a new pull request, #17790:
URL: https://github.com/apache/kafka/pull/17790
We plan to remove all ZooKeeper-related code in version 4.0. However, some
old brokers in the end-to-end tests still require ZooKeeper service, so we need
to run the ZooKeeper service using the
[
https://issues.apache.org/jira/browse/KAFKA-18004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897811#comment-17897811
]
Chia-Ping Tsai commented on KAFKA-18004:
[~yangpoan] please use https://github.c
[
https://issues.apache.org/jira/browse/KAFKA-18004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-18004:
--
Assignee: PoAn Yang (was: Chia-Ping Tsai)
> Use 3.8 to run zk service for e2e
>
[
https://issues.apache.org/jira/browse/KAFKA-18004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897810#comment-17897810
]
PoAn Yang commented on KAFKA-18004:
---
Hi [~chia7712], if you're not working on this, ma
chia7712 commented on code in PR #17768:
URL: https://github.com/apache/kafka/pull/17768#discussion_r1839392461
##
bin/zookeeper-server-start.sh:
##
@@ -1,44 +0,0 @@
-#!/bin/bash
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreeme
[
https://issues.apache.org/jira/browse/KAFKA-18004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-18004:
---
Summary: Use 3.8 to run zk service for e2e (was: Use 3.8 to run zk service)
> Use 3.8 to ru
Chia-Ping Tsai created KAFKA-18004:
--
Summary: Use 3.8 to run zk service
Key: KAFKA-18004
URL: https://issues.apache.org/jira/browse/KAFKA-18004
Project: Kafka
Issue Type: Sub-task
xijiu commented on PR #17789:
URL: https://github.com/apache/kafka/pull/17789#issuecomment-2472363186
@lianetm @chia7712 PTAL
--
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 comm
xijiu opened a new pull request, #17789:
URL: https://github.com/apache/kafka/pull/17789
First of all, the reason for the failure of this test is due to TIMEOUT, the
method `AbstractConsumerTest#validateGroupAssignment` timeout after waiting for
10 seconds. And it reproduced on my computer.
frankvicky commented on PR #17770:
URL: https://github.com/apache/kafka/pull/17770#issuecomment-2472293182
I have looped `ConsumerBounceTest` on my local machine，and it looks good
except for `testConsumptionWithBrokerFailures`, where the interval between two
`poll` calls may exceed `max.pol
[
https://issues.apache.org/jira/browse/KAFKA-18003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897804#comment-17897804
]
Kuan Po Tseng commented on KAFKA-18003:
---
Hi [~chia7712] , may I take over this iss
Chia-Ping Tsai created KAFKA-18003:
--
Summary: add test to make sure `Admin#deleteRecords` can handle
the corrupted records
Key: KAFKA-18003
URL: https://issues.apache.org/jira/browse/KAFKA-18003
Proj
[
https://issues.apache.org/jira/browse/KAFKA-18003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-18003:
--
Assignee: Kuan Po Tseng (was: Chia-Ping Tsai)
> add test to make sure `Admin#deleteR
[
https://issues.apache.org/jira/browse/KAFKA-9613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897803#comment-17897803
]
Chia-Ping Tsai commented on KAFKA-9613:
---
{quote}
I did a test on this hardware issu
chia7712 commented on PR #17778:
URL: https://github.com/apache/kafka/pull/17778#issuecomment-2472238431
LGTM
> Did we trigger a system test run to verify that the PR fixes the issue?
`streams_upgrade_test.py` pass on my local now. I will run e2e for all
streams later
--
Thi
mumrah commented on PR #17788:
URL: https://github.com/apache/kafka/pull/17788#issuecomment-2472245598
In the test-catalog, we have some errors such as:
```
org.apache.kafka.streams.test.MockProcessorContextStateStoreTest:
- builder
```
https://github.com/apache/kafka/blob
[
https://issues.apache.org/jira/browse/KAFKA-17966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897799#comment-17897799
]
Luke Chen commented on KAFKA-17966:
---
[~jsancio] [~cmccabe] , any thought about it?
>
mumrah opened a new pull request, #17788:
URL: https://github.com/apache/kafka/pull/17788
Since we parse the JUnit XML to discover test names as
`ClassName#MethodName` we need to avoid making custom test display names.
--
This is an automated message from the Apache Git Service.
To respon
dajac commented on code in PR #17750:
URL: https://github.com/apache/kafka/pull/17750#discussion_r1838780496
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/UnionSet.java:
##
@@ -0,0 +1,212 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
chia7712 commented on PR #17787:
URL: https://github.com/apache/kafka/pull/17787#issuecomment-2472177195
I’ll hold off on merging until we reach a consensus.
--
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
chia7712 opened a new pull request, #17787:
URL: https://github.com/apache/kafka/pull/17787
as title.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (inclu
[
https://issues.apache.org/jira/browse/KAFKA-16589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16589.
Resolution: Won't Fix
KAFKA-17922 refactor all helpers so we don't need to address this no
chia7712 closed pull request #15815: KAFKA-16589: Consider removing
`ClusterInstance#createAdminClient` since callers are not sure whether they
need to call close
URL: https://github.com/apache/kafka/pull/15815
--
This is an automated message from the Apache Git Service.
To respond to the me
[
https://issues.apache.org/jira/browse/KAFKA-17922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17922.
Fix Version/s: 4.0.0
Resolution: Fixed
> add helper to ClusterInstance to create cl
chia7712 commented on PR #15815:
URL: https://github.com/apache/kafka/pull/15815#issuecomment-2472136306
close due to #17666
--
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.
chia7712 merged PR #17666:
URL: https://github.com/apache/kafka/pull/17666
--
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
[
https://issues.apache.org/jira/browse/KAFKA-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-17978:
---
Fix Version/s: 4.0.0
> StreamsUpgradeTest#test_rolling_upgrade_with_2_bounces system tests f
[
https://issues.apache.org/jira/browse/KAFKA-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897789#comment-17897789
]
PoAn Yang commented on KAFKA-17978:
---
Latest result on my laptop:
{noformat}
> TC_PATH
[
https://issues.apache.org/jira/browse/KAFKA-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang resolved KAFKA-17978.
---
Resolution: Fixed
> StreamsUpgradeTest#test_rolling_upgrade_with_2_bounces system tests fail
> -
[
https://issues.apache.org/jira/browse/KAFKA-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang reassigned KAFKA-17978:
-
Assignee: Nicholas Telford (was: PoAn Yang)
> StreamsUpgradeTest#test_rolling_upgrade_with_2_b
[
https://issues.apache.org/jira/browse/KAFKA-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897788#comment-17897788
]
PoAn Yang commented on KAFKA-17978:
---
Yes, all test cases can pass now. Close the ticke
mjsax commented on code in PR #17713:
URL: https://github.com/apache/kafka/pull/17713#discussion_r1839152414
##
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java:
##
@@ -154,7 +155,13 @@ private void registerMetrics() {
StateStoreM
mjsax commented on PR #17696:
URL: https://github.com/apache/kafka/pull/17696#issuecomment-2472096178
@clolov @cmccabe @showuon -- Can we make progress on this cherry-pick? It's
currently blocking me from creating the first RC.
--
This is an automated message from the Apache Git Service.
m1a2st commented on PR #17576:
URL: https://github.com/apache/kafka/pull/17576#issuecomment-2472042211
There are some typo in there, we update the zookeeper version is 3.5.7, so
the table which is the env used to running Kafka in E2E will be:
version | support | zk client version | zk
mumrah commented on PR #17782:
URL: https://github.com/apache/kafka/pull/17782#issuecomment-2472026002
Thanks for the quick fix @kevin-wu24! You might need to update with trunk
since I merged #17779
--
This is an automated message from the Apache Git Service.
To respond to the message, p
mumrah merged PR #17779:
URL: https://github.com/apache/kafka/pull/17779
--
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.o
cmccabe commented on PR #17727:
URL: https://github.com/apache/kafka/pull/17727#issuecomment-2471996386
Convert `GssapiAuthenticationTest` :
https://github.com/apache/kafka/pull/17786/files
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-17681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-17681.
---
Resolution: Cannot Reproduce
> Fix unstable consumer_test.py#test_fencing_static_consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-16949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reopened KAFKA-16949:
---
> System test test_dynamic_logging in connect_distributed_test is failing
>
[
https://issues.apache.org/jira/browse/KAFKA-17962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-17962.
---
Resolution: Cannot Reproduce
> test_pause_and_resume_sink fails with "Failed to consume messages aft
[
https://issues.apache.org/jira/browse/KAFKA-16949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897782#comment-17897782
]
Kirk True commented on KAFKA-16949:
---
[~sagarrao]—unfortunately I'm seeing this again i
cmccabe opened a new pull request, #17786:
URL: https://github.com/apache/kafka/pull/17786
(no comment)
--
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-ma
mumrah merged PR #17772:
URL: https://github.com/apache/kafka/pull/17772
--
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.o
Kirk True created KAFKA-18002:
-
Summary: Upgrade connect_distributed_test.py's
test_exactly_once_source to support different group.protocol values
Key: KAFKA-18002
URL: https://issues.apache.org/jira/browse/KAFKA-1800
[
https://issues.apache.org/jira/browse/KAFKA-18001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897779#comment-17897779
]
Gaurav Narula commented on KAFKA-18001:
---
Potentially seems like a duplicate of KAF
cmccabe opened a new pull request, #17785:
URL: https://github.com/apache/kafka/pull/17785
(no comment)
--
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-ma
chia7712 commented on code in PR #17768:
URL: https://github.com/apache/kafka/pull/17768#discussion_r1839007241
##
bin/zookeeper-server-start.sh:
##
@@ -1,44 +0,0 @@
-#!/bin/bash
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreeme
mumrah merged PR #17746:
URL: https://github.com/apache/kafka/pull/17746
--
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.o
chia7712 commented on PR #17576:
URL: https://github.com/apache/kafka/pull/17576#issuecomment-2471861303
> I think the approach sounds fine, but wasn't sure if we typically updated
ZK like this without a KIP or anything. It is also a bit odd since it will only
be used in tests. But reading
mumrah merged PR #17762:
URL: https://github.com/apache/kafka/pull/17762
--
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.o
ahuang98 commented on PR #17773:
URL: https://github.com/apache/kafka/pull/17773#issuecomment-2471830563
Thanks @justinrlee, created
https://issues.apache.org/jira/browse/KAFKA-18001 to track, can you prepend
your PR title with `KAFKA-18001:`?
--
This is an automated message from the Apa
Alyssa Huang created KAFKA-18001:
Summary: KafkaNetworkChannel missing UpdateRaftVoterRequestData
logic
Key: KAFKA-18001
URL: https://issues.apache.org/jira/browse/KAFKA-18001
Project: Kafka
apoorvmittal10 commented on code in PR #17709:
URL: https://github.com/apache/kafka/pull/17709#discussion_r1838952613
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -315,11 +325,17 @@ else if (isolationType == FetchIsolation.HIGH_WATERMARK)
}
apoorvmittal10 commented on code in PR #17709:
URL: https://github.com/apache/kafka/pull/17709#discussion_r1838957188
##
share/src/main/java/org/apache/kafka/server/share/fetch/ShareFetch.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under o
kirktrue commented on code in PR #16686:
URL: https://github.com/apache/kafka/pull/16686#discussion_r1838922199
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -523,18 +524,45 @@ public void transitionToJoining() {
kirktrue commented on code in PR #16686:
URL: https://github.com/apache/kafka/pull/16686#discussion_r1838919865
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1216,6 +1235,81 @@ public void close(Duration timeout) {
kirktrue commented on code in PR #16686:
URL: https://github.com/apache/kafka/pull/16686#discussion_r1838921182
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1216,6 +1235,81 @@ public void close(Duration timeout) {
apoorvmittal10 commented on code in PR #17709:
URL: https://github.com/apache/kafka/pull/17709#discussion_r1838918361
##
share/src/main/java/org/apache/kafka/server/share/fetch/ShareFetch.java:
##
@@ -0,0 +1,200 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under o
kirktrue commented on code in PR #16686:
URL: https://github.com/apache/kafka/pull/16686#discussion_r1838916306
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -496,8 +496,9 @@ private void clearAssignment() {
*/
[
https://issues.apache.org/jira/browse/KAFKA-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897768#comment-17897768
]
Matthias J. Sax commented on KAFKA-17978:
-
Seems the PR was merged. Can we close
mjsax commented on PR #17778:
URL: https://github.com/apache/kafka/pull/17778#issuecomment-2471760556
Did we trigger a system test run to verify that the PR fixes the issue?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
CalvinConfluent opened a new pull request, #17784:
URL: https://github.com/apache/kafka/pull/17784
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
mjsax commented on code in PR #17781:
URL: https://github.com/apache/kafka/pull/17781#discussion_r1838848925
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -224,6 +228,34 @@ public void cleanup() {
}
}
+@Parameterized
mjsax commented on code in PR #17781:
URL: https://github.com/apache/kafka/pull/17781#discussion_r1838848038
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -3501,6 +3533,17 @@ private boolean requestGenerated(MockClient client,
ApiKeys
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897760#comment-17897760
]
Apoorv Mittal commented on KAFKA-12469:
---
[~junrao] I also looked at this patch you
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897751#comment-17897751
]
Apoorv Mittal edited comment on KAFKA-12469 at 11/12/24 9:38 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-17929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897759#comment-17897759
]
Ao Li commented on KAFKA-17929:
---
Yes, this issue exists across all Java versions. Apologie
cmccabe commented on code in PR #15702:
URL: https://github.com/apache/kafka/pull/15702#discussion_r1838830695
##
metadata/src/main/java/org/apache/kafka/controller/BrokersToElrs.java:
##
@@ -159,4 +160,12 @@ BrokersToIsrs.PartitionsOnReplicaIterator
partitionsWithBrokerInElr(i
[
https://issues.apache.org/jira/browse/KAFKA-17929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897756#comment-17897756
]
Matthias J. Sax commented on KAFKA-17929:
-
Is this still an issue with Java 11 –
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-12469:
--
Attachment: Screenshot 2024-11-12 at 21.35.59-1.png
> The topic names in the metrics do not re
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-12469:
--
Attachment: (was: Screenshot 2024-11-12 at 21.35.59.png)
> The topic names in the metrics
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-12469:
--
Attachment: (was: Screenshot 2024-11-12 at 21.35.59-2.png)
> The topic names in the metric
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-12469:
--
Attachment: (was: Screenshot 2024-11-12 at 21.35.59-1.png)
> The topic names in the metric
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897751#comment-17897751
]
Apoorv Mittal edited comment on KAFKA-12469 at 11/12/24 9:38 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897751#comment-17897751
]
Apoorv Mittal commented on KAFKA-12469:
---
Also looking at the Mbeans I do not see `
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-12469:
--
Attachment: Screenshot 2024-11-12 at 21.35.59.png
> The topic names in the metrics do not reta
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897750#comment-17897750
]
Apoorv Mittal commented on KAFKA-12469:
---
[~junrao] I verified kafka-producer, kafk
[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-12469:
--
Attachment: image-2024-11-12-21-32-55-180.png
> The topic names in the metrics do not retain t
apoorvmittal10 commented on code in PR #17739:
URL: https://github.com/apache/kafka/pull/17739#discussion_r1836502635
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -58,8 +58,8 @@ public class DelayedShareFetch extends DelayedOperation {
private fina
[
https://issues.apache.org/jira/browse/KAFKA-17278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897706#comment-17897706
]
Kevin Wu edited comment on KAFKA-17278 at 11/12/24 9:13 PM:
dajac commented on code in PR #17750:
URL: https://github.com/apache/kafka/pull/17750#discussion_r1838774665
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java:
##
@@ -89,6 +92,144 @@ public Map targetAssignment() {
kevin-wu24 opened a new pull request, #17782:
URL: https://github.com/apache/kafka/pull/17782
Verified change removes flakiness by running with no failures:
```
N=10; I=0; while [ $I -lt $N ] && ./gradlew core:test --tests
kafka.server.ReconfigurableQuorumIntegrationTest.testRemoveAn
[
https://issues.apache.org/jira/browse/KAFKA-17988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897745#comment-17897745
]
Kevin Wu commented on KAFKA-17988:
--
Submitted a PR that fixes this.
> Fix flaky Reconf
bbejeck merged PR #17716:
URL: https://github.com/apache/kafka/pull/17716
--
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.
bbejeck commented on PR #17716:
URL: https://github.com/apache/kafka/pull/17716#issuecomment-2471571031
One test failure
(`org.apache.kafka.connect.mirror.integration.DedicatedMirrorIntegrationTest.testMultiNodeCluster()`)
is unrelated
--
This is an automated message from the Apache Git
adixitconfluent commented on code in PR #17739:
URL: https://github.com/apache/kafka/pull/17739#discussion_r1838763754
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -1602,8 +1602,6 @@ protected void
updateFetchOffsetMetadata(Optional fetchOffset
prote
cmccabe commented on PR #17746:
URL: https://github.com/apache/kafka/pull/17746#issuecomment-2471509471
Sorry, forgot to push something. It should be sending to a broker, not a
controller, hence controllerSocketServer -> anySocketServer. Should be fixed
now.
--
This is an automated messa
bbejeck opened a new pull request, #17783:
URL: https://github.com/apache/kafka/pull/17783
Adding producer tests to ensure the KIP-1076 methods don't interfere with
existing metrics
*More detailed description of your change,
if necessary. The PR title and PR message become
dajac commented on code in PR #17750:
URL: https://github.com/apache/kafka/pull/17750#discussion_r1838698296
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -14979,6 +14980,83 @@ public void
testReplayConsumerGroupRegul
kevin-wu24 commented on PR #17779:
URL: https://github.com/apache/kafka/pull/17779#issuecomment-2471522963
> Report:
https://ge.apache.org/scans/tests?search.names=CI%20workflow,Git%20repository&search.relativeStartTime=P28D&search.rootProjectNames=kafka&search.tags=github,trunk&search.tasks
cmccabe merged PR #17760:
URL: https://github.com/apache/kafka/pull/17760
--
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.
jeffkbkim commented on code in PR #17750:
URL: https://github.com/apache/kafka/pull/17750#discussion_r1838730791
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java:
##
@@ -89,6 +92,144 @@ public Map targetAssignment() {
jeffkbkim commented on code in PR #17750:
URL: https://github.com/apache/kafka/pull/17750#discussion_r1838728030
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/UnionSet.java:
##
@@ -0,0 +1,212 @@
+/*
+ * Licensed to the Apache Software Foundation (A
bbejeck opened a new pull request, #17781:
URL: https://github.com/apache/kafka/pull/17781
Adding tests to ensure the KIP-1076 methods don't interfere with existing
metrics in clients
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementat
cmccabe opened a new pull request, #17780:
URL: https://github.com/apache/kafka/pull/17780
(no comment)
--
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-ma
1 - 100 of 249 matches
Mail list logo
