[
https://issues.apache.org/jira/browse/KAFKA-19275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kuan Po Tseng resolved KAFKA-19275.
---
Resolution: Fixed
> client-state and thread-state metrics are always ""Unavailable"
> --
[
https://issues.apache.org/jira/browse/KAFKA-19275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951332#comment-17951332
]
Chia-Ping Tsai commented on KAFKA-19275:
trunk:
https://github.com/apache/kafka
Chia-Ping Tsai created KAFKA-19278:
--
Summary: add test to ensure the metric does not use non-java type
Key: KAFKA-19278
URL: https://issues.apache.org/jira/browse/KAFKA-19278
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-19145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19145.
Fix Version/s: 4.1.0
Resolution: Fixed
> Move LeaderEndPoint to server module
> ---
[
https://issues.apache.org/jira/browse/KAFKA-17207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951319#comment-17951319
]
Francis Godinho commented on KAFKA-17207:
-
[~gharris1727] [~Xuze Yang] saw this
[
https://issues.apache.org/jira/browse/KAFKA-17207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951319#comment-17951319
]
Francis Godinho edited comment on KAFKA-17207 at 5/14/25 3:33 AM:
[
https://issues.apache.org/jira/browse/KAFKA-16043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951310#comment-17951310
]
zhangzhisheng commented on KAFKA-16043:
---
Expecting this feature to go live early.
[
https://issues.apache.org/jira/browse/KAFKA-16042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951311#comment-17951311
]
zhangzhisheng commented on KAFKA-16042:
---
good
> Quota Metrics based on per topic-
[
https://issues.apache.org/jira/browse/KAFKA-10897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951312#comment-17951312
]
zhangzhisheng commented on KAFKA-10897:
---
good
> kafka quota optimization
> --
David Jacot created KAFKA-19277:
---
Summary: Introduce `ConsumerGroupMessageFormatter` for the
console-consumer
Key: KAFKA-19277
URL: https://issues.apache.org/jira/browse/KAFKA-19277
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Will Perlichek reassigned KAFKA-15891:
--
Assignee: (was: Will Perlichek)
> Flaky test: testResetSinkConnectorOffsetsOverri
[
https://issues.apache.org/jira/browse/KAFKA-16492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Will Perlichek reassigned KAFKA-16492:
--
Assignee: (was: Will Perlichek)
> Flaky test: testAlterSinkConnectorOffsetsDiffer
FrankYang0529 commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2087028173
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java:
##
@@ -324,4 +329,84 @@ static void throwIfRegularExpressionIsInvalid(
junrao commented on code in PR #19635:
URL: https://github.com/apache/kafka/pull/19635#discussion_r2087319995
##
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala:
##
@@ -921,8 +923,76 @@ class AuthorizerIntegrationTest extends
AbstractAuthorizerIntegrat
ahuang98 opened a new pull request, #19711:
URL: https://github.com/apache/kafka/pull/19711
Reviewers: Colin P. McCabe
```
Conflicts:
checkstyle/import-control.xml - different surrounding imports
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCreden
ahuang98 opened a new pull request, #19710:
URL: https://github.com/apache/kafka/pull/19710
Reviewers: Colin P. McCabe
```
Conflicts:
checkstyle/import-control.xml - different surrounding imports
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCreden
dajac commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2087258500
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java:
##
@@ -324,4 +329,84 @@ static void throwIfRegularExpressionIsInvalid(
chirag-wadhwa5 opened a new pull request, #19708:
URL: https://github.com/apache/kafka/pull/19708
This PR includes the system test file test_console_share_consumer.py which
tests the functioning of ConsoleShareConsumer
--
This is an automated message from the Apache Git Service.
To respon
[
https://issues.apache.org/jira/browse/KAFKA-18961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951240#comment-17951240
]
David Jacot commented on KAFKA-18961:
-
[~squah-confluent] It is preferable to have i
dajac commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2087259372
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/UtilsTest.java:
##
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
dajac commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2087257495
##
build.gradle:
##
@@ -1414,10 +1414,12 @@ project(':group-coordinator') {
implementation project(':coordinator-common')
implementation libs.jacksonDatabind
lianetm merged PR #19622:
URL: https://github.com/apache/kafka/pull/19622
--
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.
m1a2st commented on code in PR #19371:
URL: https://github.com/apache/kafka/pull/19371#discussion_r2086829441
##
raft/src/main/java/org/apache/kafka/raft/MetadataLogConfig.java:
##
@@ -85,14 +82,13 @@ public class MetadataLogConfig {
.define(METADATA_SNAPSHOT_MAX_IN
ahuang98 commented on PR #19692:
URL: https://github.com/apache/kafka/pull/19692#issuecomment-2877132412
hm, build was "successful" but still marked unstable
```
BUILD SUCCESSFUL in 3h 42m 34s
```
--
This is an automated message from the Apache Git Service.
To respond to the messa
yunchipang opened a new pull request, #19709:
URL: https://github.com/apache/kafka/pull/19709
jira: [KAFKA-19267](https://issues.apache.org/jira/browse/KAFKA-19267)
Updates the min version used by `ListOffsetsRequest` to
`ApiKeys.LIST_OFFSETS.oldestVersion()` rather than hardcoding `1
jsancio commented on code in PR #19668:
URL: https://github.com/apache/kafka/pull/19668#discussion_r2087113715
##
raft/src/test/java/org/apache/kafka/raft/RequestManagerTest.java:
##
@@ -120,10 +131,17 @@ public void testIgnoreUnexpectedResponse() {
);
long c
apoorvmittal10 commented on code in PR #19659:
URL: https://github.com/apache/kafka/pull/19659#discussion_r2087178807
##
core/src/main/java/kafka/server/share/SharePartitionManager.java:
##
@@ -746,6 +747,29 @@ private Consumer>
failedShareAcknowledgeMetricsHandler() {
ahuang98 commented on PR #19690:
URL: https://github.com/apache/kafka/pull/19690#issuecomment-2877127401
build failed with
```
* What went wrong:
--
Execution failed for task ':connect:json:signMavenJavaPublication'.
> Cannot perform signing task ':connect:json:signMavenJavaPu
chirag-wadhwa5 commented on PR #19637:
URL: https://github.com/apache/kafka/pull/19637#issuecomment-2876988834
This PR is obsolete now. This task is now being handled in the PR ->
https://github.com/apache/kafka/pull/19701
Will close this PR
--
This is an automated message from the Apa
apoorvmittal10 commented on PR #19671:
URL: https://github.com/apache/kafka/pull/19671#issuecomment-2876997503
Also not sure if you require the commit history or can cherry-pick your
changes on top of current trunk.
--
This is an automated message from the Apache Git Service.
To respond t
apoorvmittal10 commented on PR #19671:
URL: https://github.com/apache/kafka/pull/19671#issuecomment-2876992772
Can we please have PR with corrected title and description. Also seems there
are a lot conflicts, can we please resolve them. If the PR is work in progress
then consider converting
chirag-wadhwa5 closed pull request #19637: KAFKA-19231: Handle fetch request
when share session cache is full
URL: https://github.com/apache/kafka/pull/19637
--
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
apoorvmittal10 commented on code in PR #19701:
URL: https://github.com/apache/kafka/pull/19701#discussion_r2087080717
##
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:
##
@@ -2803,6 +2804,42 @@ public void testFetchMessagesRotatePartitions() {
val
UladzislauBlok commented on code in PR #19553:
URL: https://github.com/apache/kafka/pull/19553#discussion_r2087104901
##
server/src/test/java/org/apache/kafka/server/purgatory/DelayedFutureTest.java:
##
@@ -49,13 +49,11 @@ void testDelayedFuture() throws Exception {
FrankYang0529 commented on code in PR #19553:
URL: https://github.com/apache/kafka/pull/19553#discussion_r2087095791
##
server/src/test/java/org/apache/kafka/server/purgatory/DelayedFutureTest.java:
##
@@ -49,13 +49,11 @@ void testDelayedFuture() throws Exception {
dajac commented on code in PR #19704:
URL: https://github.com/apache/kafka/pull/19704#discussion_r2087068751
##
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java:
##
@@ -239,4 +240,31 @@ public OffsetFetchResponseData data() {
public boolean sh
FrankYang0529 commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2087024185
##
build.gradle:
##
@@ -1414,10 +1414,12 @@ project(':group-coordinator') {
implementation project(':coordinator-common')
implementation libs.jacksonDat
dajac commented on PR #19677:
URL: https://github.com/apache/kafka/pull/19677#issuecomment-2876898370
Merged to trunk and 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-18688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-18688.
-
Fix Version/s: 4.0.1
4.1.0
Resolution: Fixed
> Uniform homogeneous ass
dajac merged PR #19677:
URL: https://github.com/apache/kafka/pull/19677
--
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
FrankYang0529 commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2087031341
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java:
##
@@ -324,4 +329,84 @@ static void throwIfRegularExpressionIsInvalid(
FrankYang0529 commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2087037433
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/UtilsTest.java:
##
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
FrankYang0529 commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2087027573
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java:
##
@@ -324,4 +329,84 @@ static void throwIfRegularExpressionIsInvalid(
FrankYang0529 commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2087026067
##
build.gradle:
##
@@ -1414,10 +1414,12 @@ project(':group-coordinator') {
implementation project(':coordinator-common')
implementation libs.jacksonDat
AndrewJSchofield merged PR #19659:
URL: https://github.com/apache/kafka/pull/19659
--
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...@kafk
kirktrue commented on code in PR #19622:
URL: https://github.com/apache/kafka/pull/19622#discussion_r2086871765
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/DefaultJwtRetriever.java:
##
@@ -86,6 +90,18 @@ public static AccessTokenRetrie
FrankYang0529 commented on code in PR #19493:
URL: https://github.com/apache/kafka/pull/19493#discussion_r2086922412
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -10929,47 +10928,231 @@ class KafkaApisTest extends Logging {
}
@Test
- def testListC
FrankYang0529 commented on code in PR #19493:
URL: https://github.com/apache/kafka/pull/19493#discussion_r2086921570
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2874,16 +2874,55 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
- def handleLis
kirktrue commented on code in PR #19622:
URL: https://github.com/apache/kafka/pull/19622#discussion_r2086872075
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/DefaultJwtValidator.java:
##
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache S
kirktrue commented on code in PR #19622:
URL: https://github.com/apache/kafka/pull/19622#discussion_r2086875757
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallbackHandlerTest.java:
##
@@ -106,11 +109,13 @@ public OAuthBearerToken va
AndrewJSchofield commented on code in PR #19666:
URL: https://github.com/apache/kafka/pull/19666#discussion_r2086868597
##
server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java:
##
@@ -143,6 +191,7 @@ public synchronized ShareSessionKey maybeCreateSes
kirktrue commented on code in PR #19569:
URL: https://github.com/apache/kafka/pull/19569#discussion_r2086890019
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java:
##
@@ -339,11 +339,20 @@ void cleanup() {
log.trace("Closing
lianetm merged PR #19595:
URL: https://github.com/apache/kafka/pull/19595
--
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-19201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield resolved KAFKA-19201.
--
Fix Version/s: 4.1.0
Resolution: Fixed
> Handle deletion of a topic which has i
AndrewJSchofield merged PR #19559:
URL: https://github.com/apache/kafka/pull/19559
--
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...@kafk
AndrewJSchofield commented on code in PR #19559:
URL: https://github.com/apache/kafka/pull/19559#discussion_r2086801802
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinator.java:
##
@@ -120,6 +124,14 @@ public interface ShareCoordinator {
dajac commented on PR #19611:
URL: https://github.com/apache/kafka/pull/19611#issuecomment-2876345298
@FrankYang0529 Thanks for the results. Have you also tried to run
`ServerSideAssignorBenchmark`?
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
squah-confluent commented on code in PR #19678:
URL: https://github.com/apache/kafka/pull/19678#discussion_r2086649161
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeSet.java:
##
@@ -44,6 +44,7 @@ public RangeSet(int from, int to) {
@O
lianetm commented on code in PR #19622:
URL: https://github.com/apache/kafka/pull/19622#discussion_r2086793268
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerValidatorCallbackHandlerTest.java:
##
@@ -106,11 +109,13 @@ public OAuthBearerToken val
[
https://issues.apache.org/jira/browse/KAFKA-14691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14691.
-
Fix Version/s: 4.1.0
Resolution: Fixed
> Add TopicId to OffsetFetch API
> ---
dajac merged PR #19515:
URL: https://github.com/apache/kafka/pull/19515
--
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
xijiu commented on PR #19698:
URL: https://github.com/apache/kafka/pull/19698#issuecomment-2876427443
@chia7712 Yeah, it's more appropriate to do it this way. I have fixed it,
PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
AndrewJSchofield merged PR #19705:
URL: https://github.com/apache/kafka/pull/19705
--
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...@kafk
AndrewJSchofield commented on code in PR #19707:
URL: https://github.com/apache/kafka/pull/19707#discussion_r2086734036
##
tests/kafkatest/tests/client/share_consumer_test.py:
##
@@ -248,7 +248,7 @@ def test_broker_failure(self, clean_shutdown,
metadata_quorum=quorum.isolated_k
squah-confluent commented on code in PR #19678:
URL: https://github.com/apache/kafka/pull/19678#discussion_r2086677598
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeSet.java:
##
@@ -176,8 +185,18 @@ public boolean equals(Object o) {
@
m1a2st commented on code in PR #19651:
URL: https://github.com/apache/kafka/pull/19651#discussion_r2086737025
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java:
##
@@ -2994,35 +2992,4 @@ private void waitForAssignment(Str
[
https://issues.apache.org/jira/browse/KAFKA-17541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951186#comment-17951186
]
Andrew Schofield commented on KAFKA-17541:
--
[~isding_l] I agree that case 2 wil
[
https://issues.apache.org/jira/browse/KAFKA-19245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield resolved KAFKA-19245.
--
Resolution: Fixed
> Update defaults for preview of queues configurations
> ---
AndrewJSchofield commented on code in PR #19707:
URL: https://github.com/apache/kafka/pull/19707#discussion_r2086697553
##
tests/kafkatest/tests/client/share_consumer_test.py:
##
@@ -248,7 +248,7 @@ def test_broker_failure(self, clean_shutdown,
metadata_quorum=quorum.isolated_k
dajac commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2086685337
##
build.gradle:
##
@@ -1414,10 +1414,12 @@ project(':group-coordinator') {
implementation project(':coordinator-common')
implementation libs.jacksonDatabind
m1a2st commented on code in PR #19669:
URL: https://github.com/apache/kafka/pull/19669#discussion_r2086701640
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -913,16 +914,16 @@ public void
verifyNoCoordinatorLookupForManualAssignmentWith
squah-confluent commented on code in PR #19678:
URL: https://github.com/apache/kafka/pull/19678#discussion_r2086677598
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeSet.java:
##
@@ -176,8 +185,18 @@ public boolean equals(Object o) {
@
FrankYang0529 commented on code in PR #19678:
URL: https://github.com/apache/kafka/pull/19678#discussion_r2086665383
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeSet.java:
##
@@ -163,6 +171,7 @@ public boolean equals(Object o) {
if
chirag-wadhwa5 opened a new pull request, #19707:
URL: https://github.com/apache/kafka/pull/19707
There were some tests in share_consumer_test, where the default value of
metadata_quorum was quorum.zk. That is change to quorum.isolted_kraft in this PR
--
This is an automated message from
[
https://issues.apache.org/jira/browse/KAFKA-19163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-19163.
-
Fix Version/s: 4.0.1
4.1.0
Resolution: Fixed
> New group coordinator c
dajac commented on PR #19496:
URL: https://github.com/apache/kafka/pull/19496#issuecomment-2876257768
Merged to trunk and 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
lucasbru commented on PR #19697:
URL: https://github.com/apache/kafka/pull/19697#issuecomment-2876257325
You could consider enabling `KafkaStreamsTelemetryIntegrationTest` with the
new wrapper for the new protocol to actually test that your changes work. Wdyt?
--
This is an automated mess
dajac merged PR #19496:
URL: https://github.com/apache/kafka/pull/19496
--
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
dajac commented on code in PR #19683:
URL: https://github.com/apache/kafka/pull/19683#discussion_r2086668181
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetAndMetadataTest.java:
##
@@ -16,52 +16,69 @@
*/
package org.apache.kafka.coordinator.group;
dajac commented on code in PR #19677:
URL: https://github.com/apache/kafka/pull/19677#discussion_r2086647061
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHomogeneousAssignmentBuilder.java:
##
@@ -218,6 +234,15 @@ private void maybeRevokeP
FrankYang0529 commented on code in PR #19678:
URL: https://github.com/apache/kafka/pull/19678#discussion_r2086663038
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeSet.java:
##
@@ -163,6 +171,7 @@ public boolean equals(Object o) {
if
dajac commented on code in PR #19677:
URL: https://github.com/apache/kafka/pull/19677#discussion_r2086645708
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHomogeneousAssignmentBuilder.java:
##
@@ -152,8 +152,13 @@ public GroupAssignment bu
squah-confluent commented on code in PR #19677:
URL: https://github.com/apache/kafka/pull/19677#discussion_r2086658896
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHomogeneousAssignmentBuilder.java:
##
@@ -152,8 +152,13 @@ public GroupAss
squah-confluent commented on code in PR #19677:
URL: https://github.com/apache/kafka/pull/19677#discussion_r2086658896
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHomogeneousAssignmentBuilder.java:
##
@@ -152,8 +152,13 @@ public GroupAss
squah-confluent commented on PR #19678:
URL: https://github.com/apache/kafka/pull/19678#issuecomment-2876233084
@FrankYang0529 We don't create ranges like that anywhere right now. I think
it's easy to do by accident when working with ranges in general. I had a look
around at what other rang
squah-confluent commented on code in PR #19678:
URL: https://github.com/apache/kafka/pull/19678#discussion_r2086650043
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeSetTest.java:
##
@@ -32,16 +32,30 @@
public class RangeSetTest {
+@
squah-confluent commented on code in PR #19677:
URL: https://github.com/apache/kafka/pull/19677#discussion_r2086619092
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHomogeneousAssignmentBuilder.java:
##
@@ -218,6 +234,15 @@ private void ma
FrankYang0529 commented on PR #19611:
URL: https://github.com/apache/kafka/pull/19611#issuecomment-2876171380
> Out of curiosity, have you tried to run the benchmarks before and after
the change to see the impact?
Since previous `SubscribedTopicDescriberImpl` only supports
`numOfPart
squah-confluent commented on code in PR #19704:
URL: https://github.com/apache/kafka/pull/19704#discussion_r2086497841
##
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java:
##
@@ -239,4 +240,31 @@ public OffsetFetchResponseData data() {
public
squah-confluent commented on code in PR #19683:
URL: https://github.com/apache/kafka/pull/19683#discussion_r2086490152
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetAndMetadataTest.java:
##
@@ -16,52 +16,69 @@
*/
package org.apache.kafka.coordina
[
https://issues.apache.org/jira/browse/KAFKA-17853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal reassigned KAFKA-17853:
-
Assignee: Shivsundar R (was: Jimmy Wang)
> Console share consumer is not terminated im
adixitconfluent commented on code in PR #19659:
URL: https://github.com/apache/kafka/pull/19659#discussion_r2086477440
##
core/src/main/java/kafka/server/share/SharePartitionManager.java:
##
@@ -455,9 +468,12 @@ public ShareFetchContext newContext(
Impli
fvaleri commented on PR #19706:
URL: https://github.com/apache/kafka/pull/19706#issuecomment-2875838111
cc @mimaison
--
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 uns
fvaleri opened a new pull request, #19706:
URL: https://github.com/apache/kafka/pull/19706
According to KIP-830, in Kafka 4 users currently relying on JmxReporter and
that are using additional reporters via metric.reporters will have to include
org.apache.kafka.common.metrics.JmxReporter in
[
https://issues.apache.org/jira/browse/KAFKA-17541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951151#comment-17951151
]
Apoorv Mittal commented on KAFKA-17541:
---
[~isding_l] May be KAFKA-19020 can be hel
AndrewJSchofield commented on code in PR #19701:
URL: https://github.com/apache/kafka/pull/19701#discussion_r2086392228
##
core/src/main/java/kafka/server/share/IdleShareFetchTimeTask.java:
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
apoorvmittal10 opened a new pull request, #19705:
URL: https://github.com/apache/kafka/pull/19705
Updated default locks config for share groups from 200 to 2000. The increase
in the limit is a result from tests which showed that with default
maxFetchRecords of 500 from client and 200 as loc
AndrewJSchofield merged PR #19688:
URL: https://github.com/apache/kafka/pull/19688
--
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...@kafk
squah-confluent commented on code in PR #19677:
URL: https://github.com/apache/kafka/pull/19677#discussion_r2086378831
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHomogeneousAssignmentBuilder.java:
##
@@ -218,6 +234,15 @@ private void ma
squah-confluent commented on code in PR #19496:
URL: https://github.com/apache/kafka/pull/19496#discussion_r2086375860
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -1006,7 +1006,7 @@ public boolean cleanupExpiredOffsets(
1 - 100 of 133 matches
Mail list logo
