ShivsundarR commented on code in PR #19818:
URL: https://github.com/apache/kafka/pull/19818#discussion_r2108331701
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareMembershipManagerTest.java:
##
@@ -561,10 +568,42 @@ public void
testIgnoreHeartbeatRespo
dajac commented on code in PR #19790:
URL: https://github.com/apache/kafka/pull/19790#discussion_r2108336679
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupTest.java:
##
@@ -1576,6 +1581,7 @@ public void testFromClassicGroup()
ShivsundarR commented on code in PR #19818:
URL: https://github.com/apache/kafka/pull/19818#discussion_r2108331701
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ShareMembershipManagerTest.java:
##
@@ -561,10 +568,42 @@ public void
testIgnoreHeartbeatRespo
frankvicky commented on PR #19817:
URL: https://github.com/apache/kafka/pull/19817#issuecomment-2911237948
@cmccabe: Could you please take a look when you have a free moment?
Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
nick-zh commented on PR #19685:
URL: https://github.com/apache/kafka/pull/19685#issuecomment-2911205618
While I would love to help, I think you meant a different Nick @chia7712
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Luke Chen created KAFKA-19336:
-
Summary: Upgrade jackson libs since v2.16 is not maintained anymore
Key: KAFKA-19336
URL: https://issues.apache.org/jira/browse/KAFKA-19336
Project: Kafka
Issue Ty
adixitconfluent opened a new pull request, #19823:
URL: https://github.com/apache/kafka/pull/19823
### About
Added test memory records to avoid the silent exception thrown during
slicing.
### Testing
Ran the tests of `DelayedShareFetchTest` to make sure that there is no
silent
[
https://issues.apache.org/jira/browse/KAFKA-19336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954207#comment-17954207
]
Szu-Yung Wang commented on KAFKA-19336:
---
Hi, May I take this?
> Upgrade jackson l
[
https://issues.apache.org/jira/browse/KAFKA-19334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TengYao Chi updated KAFKA-19334:
Fix Version/s: 3.9.2
4.0.1
4.1.0
> MetadataShell bypasses fi
[
https://issues.apache.org/jira/browse/KAFKA-19336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Szu-Yung Wang reassigned KAFKA-19336:
-
Assignee: Szu-Yung Wang
> Upgrade jackson libs since v2.16 is not maintained anymore
>
github-actions[bot] commented on PR #18072:
URL: https://github.com/apache/kafka/pull/18072#issuecomment-2911010040
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the P
github-actions[bot] commented on PR #18921:
URL: https://github.com/apache/kafka/pull/18921#issuecomment-2911010160
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the P
frankvicky commented on code in PR #19793:
URL: https://github.com/apache/kafka/pull/19793#discussion_r2108058643
##
core/src/test/scala/kafka/server/LocalLeaderEndPointTest.scala:
##
@@ -271,9 +271,10 @@ class LocalLeaderEndPointTest extends Logging {
github-actions[bot] commented on PR #18903:
URL: https://github.com/apache/kafka/pull/18903#issuecomment-2911010127
This PR is being marked as stale since it has not had any activity in 90
days. If you
would like to keep this PR alive, please leave a comment asking for a
review. If the P
TaiJuWu opened a new pull request, #19822:
URL: https://github.com/apache/kafka/pull/19822
Delete this text and replace it with a detailed description of your change.
The
PR title and body will become the squashed commit message.
If you would like to tag individuals, add some comm
github-actions[bot] commented on PR #19231:
URL: https://github.com/apache/kafka/pull/19231#issuecomment-2910989370
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
hvishwanath opened a new pull request, #19821:
URL: https://github.com/apache/kafka/pull/19821
4.0 Markdown docs
--
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 unsu
github-actions[bot] commented on PR #19236:
URL: https://github.com/apache/kafka/pull/19236#issuecomment-2910989346
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19750:
URL: https://github.com/apache/kafka/pull/19750#issuecomment-2910989126
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19703:
URL: https://github.com/apache/kafka/pull/19703#issuecomment-2910989162
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19764:
URL: https://github.com/apache/kafka/pull/19764#issuecomment-2910989098
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
TaiJuWu commented on PR #19773:
URL: https://github.com/apache/kafka/pull/19773#issuecomment-2910955102
Hi @brandboat , thanks for your detailed review and point out my mistakes,
all comments are addressed, PTAL.
--
This is an automated message from the Apache Git Service.
To respond to t
TaiJuWu commented on code in PR #19773:
URL: https://github.com/apache/kafka/pull/19773#discussion_r2108058182
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerAssignTest.java:
##
@@ -0,0 +1,314 @@
+/*
+ * Licensed to the Apac
brandboat commented on code in PR #19773:
URL: https://github.com/apache/kafka/pull/19773#discussion_r2108051296
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerAssignTest.java:
##
@@ -0,0 +1,314 @@
+/*
+ * Licensed to the Ap
m1a2st commented on code in PR #19810:
URL: https://github.com/apache/kafka/pull/19810#discussion_r2107996769
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerWithLegacyMessageFormatIntegrationTest.java:
##
@@ -0,0 +1,226 @@
+/*
+ * Li
JimmyWang6 opened a new pull request, #19820:
URL: https://github.com/apache/kafka/pull/19820
[KAFKA-16720](https://issues.apache.org/jira/browse/KAFKA-16720) aims to
finish the AlterShareGroupOffsets for ShareGroupCommand part.
--
This is an automated message from the Apache Git Servi
m1a2st commented on code in PR #19807:
URL: https://github.com/apache/kafka/pull/19807#discussion_r2107979149
##
server/src/main/java/org/apache/kafka/server/ClientQuotaManager.java:
##
@@ -0,0 +1,938 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
FrankYang0529 commented on code in PR #19761:
URL: https://github.com/apache/kafka/pull/19761#discussion_r2107946911
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java:
##
@@ -349,12 +349,19 @@ static void throwIfRegularExpressionIsInvalid(
*
FrankYang0529 commented on code in PR #19761:
URL: https://github.com/apache/kafka/pull/19761#discussion_r2107946290
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/ModernGroup.java:
##
@@ -398,6 +423,21 @@ public Map
computeSubscriptionMetadata(
FrankYang0529 commented on code in PR #19761:
URL: https://github.com/apache/kafka/pull/19761#discussion_r2107945239
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -20635,12 +21067,10 @@ barTopicName, new TopicMetadata(
[
https://issues.apache.org/jira/browse/KAFKA-19292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-19292:
Component/s: streams
> Introduce soft state for StreamsGroup
> ---
AndrewJSchofield commented on PR #19778:
URL: https://github.com/apache/kafka/pull/19778#issuecomment-2910658074
@chirag-wadhwa5 Please merge latest changes.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-19268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield resolved KAFKA-19268.
--
Fix Version/s: 4.1.0
Resolution: Fixed
> Missing mocks for SharePartitionManage
AndrewJSchofield merged PR #19786:
URL: https://github.com/apache/kafka/pull/19786
--
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
whybeeh1 commented on PR #19819:
URL: https://github.com/apache/kafka/pull/19819#issuecomment-2910631422
l
--
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
whybeeh1 commented on PR #19819:
URL: https://github.com/apache/kafka/pull/19819#issuecomment-2910613900
cl
--
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,
whybeeh1 closed pull request #19819: Update README.md
URL: https://github.com/apache/kafka/pull/19819
--
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: ji
whybeeh1 opened a new pull request, #19819:
URL: https://github.com/apache/kafka/pull/19819
Better readability
--
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 unsubscrib
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2107840373
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -155,6 +155,7 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
cadonna commented on code in PR #19275:
URL: https://github.com/apache/kafka/pull/19275#discussion_r2107363103
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java:
##
@@ -446,29 +446,15 @@ private List getTask
dongnuo123 commented on code in PR #19790:
URL: https://github.com/apache/kafka/pull/19790#discussion_r2107834673
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2485,8 +2485,6 @@ class PlaintextAdminIntegrationTest extends
BaseAdminInte
dongnuo123 commented on code in PR #19790:
URL: https://github.com/apache/kafka/pull/19790#discussion_r210783
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupTest.java:
##
@@ -1576,6 +1581,7 @@ public void testFromClassicGro
lianetm commented on code in PR #19744:
URL: https://github.com/apache/kafka/pull/19744#discussion_r2107800303
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -859,6 +859,7 @@ boolean hasCommittedOffset(
*
* @re
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2107803984
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -428,18 +427,19 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
chia7712 commented on PR #19685:
URL: https://github.com/apache/kafka/pull/19685#issuecomment-2910266692
@nick-zh 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 to go to the spec
ahuang98 commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2107754429
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -428,18 +427,19 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
try
ahuang98 commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2107750048
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -453,40 +452,34 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
}
dajac commented on PR #19761:
URL: https://github.com/apache/kafka/pull/19761#issuecomment-2909780629
I would like to merge https://github.com/apache/kafka/pull/19790 before
merging this one because we need to cherry-pick it to 4.0.
--
This is an automated message from the Apache Git Serv
lucasbru commented on PR #19818:
URL: https://github.com/apache/kafka/pull/19818#issuecomment-2910391860
> Thoughts? not sure if I'm missing something here
Thanks for taking a look, @lianetm ! You are right, consumer groups and
share groups should fail with `UNKNOWN_MEMBER`. In stream
lucasbru commented on code in PR #19802:
URL: https://github.com/apache/kafka/pull/19802#discussion_r2107633695
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java:
##
@@ -582,54 +592,44 @@ public Set currentWarmupTaskProcessIds(
lianetm commented on PR #19818:
URL: https://github.com/apache/kafka/pull/19818#issuecomment-2910378099
Hey @lucasbru, thanks for taking on this one. Agree with the gap on leave HB
responses received in unexpected order. And the fix makes sense to me (only
complete the leave if the HB respo
FrankYang0529 commented on code in PR #19802:
URL: https://github.com/apache/kafka/pull/19802#discussion_r2107522589
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java:
##
@@ -582,54 +592,44 @@ public Set currentWarmupTaskProcessIds(
chia7712 commented on code in PR #19807:
URL: https://github.com/apache/kafka/pull/19807#discussion_r2107643996
##
server/src/main/java/org/apache/kafka/server/PermissiveControllerMutationQuota.java:
##
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
chia7712 commented on PR #19793:
URL: https://github.com/apache/kafka/pull/19793#issuecomment-2910286667
@johnny94 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 to go to the spe
[
https://issues.apache.org/jira/browse/KAFKA-19322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19322.
Fix Version/s: 4.1.0
Resolution: Fixed
> Remove the DelayedOperation constructor th
chia7712 merged PR #19798:
URL: https://github.com/apache/kafka/pull/19798
--
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-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19300.
Resolution: Fixed
> AsyncConsumer#unsubscribe always timeout due to GroupAuthorizationExce
chia7712 merged PR #19779:
URL: https://github.com/apache/kafka/pull/19779
--
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
mingyen066 commented on PR #19812:
URL: https://github.com/apache/kafka/pull/19812#issuecomment-2910251765
@chia7712 Thanks for the review. I've addressed the comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/KAFKA-19288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954116#comment-17954116
]
Lucas Brutschy commented on KAFKA-19288:
The sequence is slightly different from
chia7712 commented on code in PR #19812:
URL: https://github.com/apache/kafka/pull/19812#discussion_r2107630603
##
clients/src/test/java/org/apache/kafka/test/MockDeserializer.java:
##
@@ -52,11 +53,14 @@ public void configure(Map configs, boolean
isKey) {
}
@Overri
[
https://issues.apache.org/jira/browse/KAFKA-19288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954114#comment-17954114
]
Lucas Brutschy commented on KAFKA-19288:
https://github.com/apache/kafka/pull/19
[
https://issues.apache.org/jira/browse/KAFKA-19288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-19288:
--
Assignee: Lucas Brutschy (was: Lianet Magrans)
> Ensure new consumer joining attempt
lucasbru opened a new pull request, #19818:
URL: https://github.com/apache/kafka/pull/19818
There is a sequence of interactions with the membership managers of KIP-848,
KIP-932, KIP-1071 that can put the member ship manager into JOINING state, but
where member epoch is set to -1. This can r
[
https://issues.apache.org/jira/browse/KAFKA-19335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-19335:
--
Assignee: Lucas Brutschy
> Streams group heartbeat sometimes fails with INVALID_REQUE
Lucas Brutschy created KAFKA-19335:
--
Summary: Streams group heartbeat sometimes fails with
INVALID_REQUEST
Key: KAFKA-19335
URL: https://issues.apache.org/jira/browse/KAFKA-19335
Project: Kafka
mingyen066 commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2107586894
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,230 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
[
https://issues.apache.org/jira/browse/KAFKA-19333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954108#comment-17954108
]
Nick Guo commented on KAFKA-19333:
--
Hi [~lianetm] ! Thanks for taking time to explain t
[
https://issues.apache.org/jira/browse/KAFKA-19334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954105#comment-17954105
]
Haruki Okada commented on KAFKA-19334:
--
[~cmccabe] Submitted a patch for this. Coul
ocadaruma opened a new pull request, #19817:
URL: https://github.com/apache/kafka/pull/19817
## Summary
- MetadataShell may deletes lock file unintentionally when it exists or
fails to acquire lock. If there's running server, this causes unexpected result
as below:
* MetadataShell s
MahsaSeifikar commented on code in PR #19742:
URL: https://github.com/apache/kafka/pull/19742#discussion_r2107467714
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -453,40 +452,34 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
Chuckame opened a new pull request, #19816:
URL: https://github.com/apache/kafka/pull/19816
Currently, building the topology with custom graph nodes fails with a NPE
because the GraphNode#buildPriority field is null. We can set this value to an
empiric one (like taking the one from the prev
dajac commented on PR #19815:
URL: https://github.com/apache/kafka/pull/19815#issuecomment-2909952792
@FrankYang0529 Thanks for the patch. Could you highlight the places where
using `mapKey` is useful? It seems that most of the changes are unrelated.
--
This is an automated message from t
Haruki Okada created KAFKA-19334:
Summary: MetadataShell bypasses file lock unexpectedly due to lock
file deletion
Key: KAFKA-19334
URL: https://issues.apache.org/jira/browse/KAFKA-19334
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-19333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-19333:
---
Component/s: clients
streams
> Inconsistent behavior between `ConsumerMembe
[
https://issues.apache.org/jira/browse/KAFKA-19333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954099#comment-17954099
]
Lianet Magrans commented on KAFKA-19333:
Hey [~lansg]! Just to add context from
jkt628 commented on PR #16492:
URL: https://github.com/apache/kafka/pull/16492#issuecomment-2909788972
note `test for client.id` moved to
https://github.com/apache/kafka/blob/trunk/tools/src/test/java/org/apache/kafka/tools/ConsoleProducerTest.java
--
This is an automated message from the
FrankYang0529 commented on code in PR #19761:
URL: https://github.com/apache/kafka/pull/19761#discussion_r2107213749
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java:
##
@@ -349,12 +349,19 @@ static void throwIfRegularExpressionIsInvalid(
*
dajac commented on code in PR #19761:
URL: https://github.com/apache/kafka/pull/19761#discussion_r2107327586
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -3624,24 +3629,28 @@ private UpdateSubscriptionMetadataResult
upda
cadonna commented on PR #19275:
URL: https://github.com/apache/kafka/pull/19275#issuecomment-2909713453
Hi @janchilling ,
Sorry for the long silence but I was quite busy recently.
Yeah, I agree with you about the bug regarding the state updater thread that
is not torn down afte
[
https://issues.apache.org/jira/browse/KAFKA-19332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit updated KAFKA-19332:
--
Summary: Fix flaky test :
testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck
Rancho-7 commented on code in PR #19779:
URL: https://github.com/apache/kafka/pull/19779#discussion_r2107277009
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -443,7 +443,7 @@ public void transitionToFatal() {
FrankYang0529 opened a new pull request, #19815:
URL: https://github.com/apache/kafka/pull/19815
The mapKey optimisation can be used in some KIP-932 RPC schemas to improve
efficiency of some key-based accesses.
For ShareFetch, ShareAcknowledge, ShareGroupHeartbeat and
ShareGroupDescr
Nick Guo created KAFKA-19333:
Summary: Inconsistent behavior between `ConsumerMembershipManager`
and `StreamsMembershipManager` on `onAllTasksLost` execution
Key: KAFKA-19333
URL: https://issues.apache.org/jira/browse
Shivsundar R created KAFKA-19332:
Summary: Fix flaky test :
testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck
Key: KAFKA-19332
URL: https://issues.apache.org/jira/browse/KAFKA-19332
DL1231 commented on PR #19577:
URL: https://github.com/apache/kafka/pull/19577#issuecomment-2909614033
@lianetm @dajac, PTAL when you get a chance.
--
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
FrankYang0529 commented on code in PR #19808:
URL: https://github.com/apache/kafka/pull/19808#discussion_r2107254802
##
core/src/main/scala/kafka/admin/ConfigCommand.scala:
##
@@ -342,6 +342,42 @@ object ConfigCommand extends Logging {
}
private def describeResourceConfi
FrankYang0529 commented on code in PR #19761:
URL: https://github.com/apache/kafka/pull/19761#discussion_r2107245093
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java:
##
@@ -151,6 +152,8 @@ public String toLowerCaseString()
FrankYang0529 commented on code in PR #19761:
URL: https://github.com/apache/kafka/pull/19761#discussion_r2107242601
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -2220,6 +2227,11 @@ private
CoordinatorResult
int
[
https://issues.apache.org/jira/browse/KAFKA-19332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit reassigned KAFKA-19332:
-
Assignee: (was: Abhinav Dixit)
> Fix flaky test :
> testAlterReadCommittedToReadUn
[
https://issues.apache.org/jira/browse/KAFKA-19332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shivsundar R reassigned KAFKA-19332:
Assignee: Abhinav Dixit
> Fix flaky test :
> testAlterReadCommittedToReadUncommittedIsol
lianetm opened a new pull request, #19814:
URL: https://github.com/apache/kafka/pull/19814
This PR uses topic IDs received in assignment (under new protocol) to ensure
that only these assigned topics are included in the consumer metadata requests
performed when the user subscribes to broker
sjhajharia commented on PR #19791:
URL: https://github.com/apache/kafka/pull/19791#issuecomment-2909416974
Hey @m1a2st
I have updated the PR
--
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 th
lucasbru commented on code in PR #19813:
URL: https://github.com/apache/kafka/pull/19813#discussion_r2107119425
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java:
##
@@ -346,18 +346,18 @@ private void optimizeTopology(final Propertie
[
https://issues.apache.org/jira/browse/KAFKA-19331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-19331:
--
Summary: No error handling for leader not appeared in
applyLocalFollowersDelta (was: No error handli
aliehsaeedii opened a new pull request, #19813:
URL: https://github.com/apache/kafka/pull/19813
As of https://github.com/apache/kafka/pull/19758#discussion_r2097734386, the
capitalization across all messages are aligned.
--
This is an automated message from the Apache Git Service.
To
aliehsaeedii commented on code in PR #19646:
URL: https://github.com/apache/kafka/pull/19646#discussion_r2107061356
##
tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java:
##
@@ -330,13 +400,433 @@ Map
getOffsets(StreamsGroupDescription description)
lucasbru commented on code in PR #19802:
URL: https://github.com/apache/kafka/pull/19802#discussion_r2106982543
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java:
##
@@ -582,54 +592,44 @@ public Set currentWarmupTaskProcessIds(
aliehsaeedii commented on code in PR #19646:
URL: https://github.com/apache/kafka/pull/19646#discussion_r2107042451
##
tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java:
##
@@ -330,13 +400,433 @@ Map
getOffsets(StreamsGroupDescription description)
dajac commented on PR #19796:
URL: https://github.com/apache/kafka/pull/19796#issuecomment-2909150320
This one should basically be a copy of
https://github.com/apache/kafka/pull/19761. Let's merge that one first and then
we can review this one.
--
This is an automated message from the Ap
1 - 100 of 114 matches
Mail list logo
