dajac commented on code in PR #15221:
URL: https://github.com/apache/kafka/pull/15221#discussion_r1458553635
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -856,7 +899,8 @@ public boolean cleanupExpiredOffsets(String group
dajac commented on PR #15221:
URL: https://github.com/apache/kafka/pull/15221#issuecomment-1899953142
@jeffkbkim @dongnuo123 Thanks for your comments. I addressed them.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
dajac commented on code in PR #15196:
URL: https://github.com/apache/kafka/pull/15196#discussion_r1458564906
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -1098,30 +1054,36 @@ private static boolean isGroupIdNotEmpty(St
dajac commented on PR #15196:
URL: https://github.com/apache/kafka/pull/15196#issuecomment-1899964532
@jeffkbkim @dongnuo123 Thanks for your comments. I have addressed all of
them.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
dajac commented on code in PR #15212:
URL: https://github.com/apache/kafka/pull/15212#discussion_r1458570521
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -875,30 +875,43 @@ private void maybeRemovePartitionEpoch(
dajac commented on code in PR #15205:
URL: https://github.com/apache/kafka/pull/15205#discussion_r1458581509
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroupMember.java:
##
@@ -571,15 +577,29 @@ public ConsumerGroupDescribeResponseData
kamalcph commented on code in PR #15213:
URL: https://github.com/apache/kafka/pull/15213#discussion_r1458560112
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1300,18 +1303,27 @@ class UnifiedLog(@volatile var logStartOffset: Long,
} else if (targetTimestamp ==
[
https://issues.apache.org/jira/browse/KAFKA-16144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-16144:
---
Fix Version/s: 3.7.0
> Controller leader checkQuorum timer should skip only 1 controller cas
danielgospodinow closed pull request #12712: KAFKA-14277: Add event queue size
method
URL: https://github.com/apache/kafka/pull/12712
--
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 com
[
https://issues.apache.org/jira/browse/KAFKA-16144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-16144:
---
Priority: Blocker (was: Major)
> Controller leader checkQuorum timer should skip only 1 con
[
https://issues.apache.org/jira/browse/KAFKA-16144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808548#comment-17808548
]
Mickael Maison commented on KAFKA-16144:
Marking this as a blocker as it's a reg
kamalcph commented on code in PR #15213:
URL: https://github.com/apache/kafka/pull/15213#discussion_r1458606590
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1300,18 +1303,27 @@ class UnifiedLog(@volatile var logStartOffset: Long,
} else if (targetTimestamp ==
[
https://issues.apache.org/jira/browse/KAFKA-16144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808548#comment-17808548
]
Mickael Maison edited comment on KAFKA-16144 at 1/19/24 9:11 AM:
-
ppatierno commented on code in PR #15193:
URL: https://github.com/apache/kafka/pull/15193#discussion_r1458520337
##
docs/ops.html:
##
@@ -3992,6 +3979,75 @@ Finalizing the migration
# Other configs ...
+ Reverting to ZooKeeper mode During the Migration
+
+While the c
lucasbru merged PR #15206:
URL: https://github.com/apache/kafka/pull/15206
--
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
dajac commented on code in PR #15152:
URL: https://github.com/apache/kafka/pull/15152#discussion_r1458663082
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -452,21 +453,39 @@ public Group group(String groupId, long committe
dajac commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1458665622
##
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java:
##
@@ -21,95 +21,111 @@
import java.util.Optional;
Review Comment:
We would need t
[
https://issues.apache.org/jira/browse/KAFKA-16162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808578#comment-17808578
]
Luke Chen commented on KAFKA-16162:
---
Thanks [~pprovenzano], I agree we also need to ha
David Jacot created KAFKA-16168:
---
Summary: Implement GroupCoordinator.onPartitionsDeleted
Key: KAFKA-16168
URL: https://issues.apache.org/jira/browse/KAFKA-16168
Project: Kafka
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-16111:
--
Assignee: (was: Lucas Brutschy)
> Implement tests for tricky rebalance callback s
mimaison commented on code in PR #15158:
URL: https://github.com/apache/kafka/pull/15158#discussion_r1458684850
##
checkstyle/import-control-core.xml:
##
@@ -82,6 +82,7 @@
+
Review Comment:
Do we really need this change? core seems to build fine without
stanislavkozlovski commented on code in PR #15186:
URL: https://github.com/apache/kafka/pull/15186#discussion_r1458752762
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -376,25 +376,21 @@ protected Map
prepareCloseFetchSessi
divijvaidya commented on PR #14583:
URL: https://github.com/apache/kafka/pull/14583#issuecomment-1900157802
@atu-sharm would you like to continue on this 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 abov
[
https://issues.apache.org/jira/browse/KAFKA-16148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-16148:
---
Assignee: Jeff Kim
> Implement GroupMetadataManager#onUnloaded
> --
Joker-5 commented on PR #14963:
URL: https://github.com/apache/kafka/pull/14963#issuecomment-1900231164
> @Joker-5 I can add it in the PR description so that I don't forget. But
the tag needs to added to the final commit, once we merge it, so we cannot
really add it yet
Got it, many
divijvaidya commented on code in PR #15133:
URL: https://github.com/apache/kafka/pull/15133#discussion_r1458819718
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -529,20 +564,33 @@ class BrokerTopicMetrics(name: Option[String], configOpt:
java.util.Optiona
cadonna commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1458727101
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetCommitCallbackInvoker.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Apache Software Found
lucasbru merged PR #15210:
URL: https://github.com/apache/kafka/pull/15210
--
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
showuon commented on PR #15133:
URL: https://github.com/apache/kafka/pull/15133#issuecomment-1900326555
> Most are optional comments but the blocking comments before we merge are
the once related to removal of metrics when topic is deleted. I would assume
that removal needs to occur from ne
VictorvandenHoven commented on PR #14426:
URL: https://github.com/apache/kafka/pull/14426#issuecomment-1900331266
> @mjsax , @guozhangwang , can we merge this?
How long does it normally take to get a reaction?
--
This is an automated message from the Apache Git Service.
To respond t
dajac commented on code in PR #15215:
URL: https://github.com/apache/kafka/pull/15215#discussion_r1458965028
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -1134,9 +1134,22 @@ private CompletableFuture assignPartitions(
[
https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808653#comment-17808653
]
Francois Visconte commented on KAFKA-15776:
---
[~ckamal] Any idea on how to move
apoorvmittal10 commented on PR #15228:
URL: https://github.com/apache/kafka/pull/15228#issuecomment-1900431524
> Thanks @apoorvmittal10!
>
> Merged to `trunk` and cherry-picked to `3.7` branch.
Thanks @mjsax
--
This is an automated message from the Apache Git Service.
To res
[
https://issues.apache.org/jira/browse/KAFKA-16162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808658#comment-17808658
]
Proven Provenzano commented on KAFKA-16162:
---
Hi [~showuon]
I think my pat
AndrewJSchofield commented on code in PR #15234:
URL: https://github.com/apache/kafka/pull/15234#discussion_r1459018939
##
server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java:
##
@@ -433,4 +459,26 @@ public Map matchPattern() {
return matchPattern
AndrewJSchofield commented on code in PR #15215:
URL: https://github.com/apache/kafka/pull/15215#discussion_r1459040148
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -1134,9 +1134,22 @@ private CompletableFuture assignPart
AndrewJSchofield commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1459047606
##
clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java:
##
@@ -34,13 +35,24 @@ public class ListConsumerGroupsOptions extends
Lucas Brutschy created KAFKA-16169:
--
Summary: FencedException in commitAsync not propagated without
callback
Key: KAFKA-16169
URL: https://issues.apache.org/jira/browse/KAFKA-16169
Project: Kafka
Vedarth Sharma created KAFKA-16170:
--
Summary: Infinite logs observed when running single node kafka in
kraft mode with default KRaft properties in 3.7.0 RC2
Key: KAFKA-16170
URL: https://issues.apache.org/jira/br
[
https://issues.apache.org/jira/browse/KAFKA-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15832:
---
Description:
Currently the reconciliation logic on the client is triggered when a new target
lucasbru commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1459046282
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetCommitCallbackInvoker.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Apache Software Foun
[
https://issues.apache.org/jira/browse/KAFKA-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15832:
---
Description:
Currently the reconciliation logic on the client is triggered when a new target
[
https://issues.apache.org/jira/browse/KAFKA-16170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vedarth Sharma updated KAFKA-16170:
---
Summary: Continuous never ending logs observed when running single node
kafka in kraft mode
[
https://issues.apache.org/jira/browse/KAFKA-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15832:
---
Description:
Currently the reconciliation logic on the client is triggered when a new target
[
https://issues.apache.org/jira/browse/KAFKA-16170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-16170.
Resolution: Duplicate
Duplicate of https://issues.apache.org/jira/browse/KAFKA-16144
> Co
OmniaGM commented on code in PR #15158:
URL: https://github.com/apache/kafka/pull/15158#discussion_r1459158610
##
core/src/test/scala/unit/kafka/utils/PasswordEncoderTest.scala:
##
@@ -19,10 +19,9 @@ package kafka.utils
import javax.crypto.SecretKeyFactory
-
-import kafka.s
OmniaGM commented on code in PR #15158:
URL: https://github.com/apache/kafka/pull/15158#discussion_r1459167324
##
server/src/main/java/org/apache/kafka/server/config/Defaults.java:
##
@@ -0,0 +1,278 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
OmniaGM commented on code in PR #15158:
URL: https://github.com/apache/kafka/pull/15158#discussion_r1459167766
##
server/src/main/java/org/apache/kafka/server/config/Defaults.java:
##
@@ -0,0 +1,278 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
OmniaGM commented on code in PR #15158:
URL: https://github.com/apache/kafka/pull/15158#discussion_r1459168180
##
core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala:
##
@@ -53,7 +53,7 @@ class LogCleanerManagerTest extends Logging {
val logConfig: LogConfig = new
OmniaGM commented on code in PR #15158:
URL: https://github.com/apache/kafka/pull/15158#discussion_r1459169205
##
checkstyle/import-control-core.xml:
##
@@ -82,6 +82,7 @@
+
Review Comment:
nope, I think this was left over from the main pr
--
This is
AyoubOm commented on PR #15162:
URL: https://github.com/apache/kafka/pull/15162#issuecomment-1900594772
@ableegoldman @mjsax I added a section for `client.id`, the result looks
like this:
https://github.com/apache/kafka/assets/23745892/9934893b-967d-44a6-842b-51b8b3cd43a8";>
Pl
ijuma opened a new pull request, #15236:
URL: https://github.com/apache/kafka/pull/15236
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
mimaison commented on code in PR #15158:
URL: https://github.com/apache/kafka/pull/15158#discussion_r1459178820
##
core/src/test/scala/unit/kafka/utils/PasswordEncoderTest.scala:
##
@@ -19,10 +19,9 @@ package kafka.utils
import javax.crypto.SecretKeyFactory
-
-import kafka.
[
https://issues.apache.org/jira/browse/KAFKA-16169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808701#comment-17808701
]
Lianet Magrans commented on KAFKA-16169:
Hey [~lbrutschy], I'm currently working
lianetm commented on code in PR #15215:
URL: https://github.com/apache/kafka/pull/15215#discussion_r1459204272
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -1134,9 +1134,22 @@ private CompletableFuture assignPartitions(
stanislavkozlovski commented on PR #15235:
URL: https://github.com/apache/kafka/pull/15235#issuecomment-1900646211
I guess this is a regression from
https://issues.apache.org/jira/browse/KAFKA-15489 ?
--
This is an automated message from the Apache Git Service.
To respond to the message,
mimaison commented on PR #15235:
URL: https://github.com/apache/kafka/pull/15235#issuecomment-1900657870
Yes, this issue was introduced in
https://github.com/apache/kafka/commit/37416e1aebae33d01d5059ba906ec8e0e1107284
--
This is an automated message from the Apache Git Service.
To respon
David Arthur created KAFKA-16171:
Summary: Controller failover during ZK migration can lead to
controller unavailability for ZK brokers
Key: KAFKA-16171
URL: https://issues.apache.org/jira/browse/KAFKA-16171
[
https://issues.apache.org/jira/browse/KAFKA-16171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-16171:
-
Component/s: controller
kraft
> Controller failover during ZK migration can lea
[
https://issues.apache.org/jira/browse/KAFKA-16171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-16171:
-
Summary: Controller failover during ZK migration can prevent metadata
updates to ZK brokers (wa
[
https://issues.apache.org/jira/browse/KAFKA-16171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-16171:
-
Affects Version/s: 3.6.1
3.6.0
3.7.0
> Controller
[
https://issues.apache.org/jira/browse/KAFKA-16171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-16171:
-
Description:
h2. Description
During the ZK migration, after KRaft becomes the active controller
cadonna commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1459255586
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -271,6 +283,7 @@ public CompletableFuture
maybeAutoCommitAllConsu
kirktrue commented on code in PR #15186:
URL: https://github.com/apache/kafka/pull/15186#discussion_r1459258946
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -376,25 +376,21 @@ protected Map
prepareCloseFetchSessi
final
[
https://issues.apache.org/jira/browse/KAFKA-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-16113.
Resolution: Fixed
> AsyncKafkaConsumer: Add missing offset commit metrics
> --
lucasbru commented on code in PR #15000:
URL: https://github.com/apache/kafka/pull/15000#discussion_r1459285186
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -271,6 +283,7 @@ public CompletableFuture
maybeAutoCommitAllCons
dajac opened a new pull request, #15237:
URL: https://github.com/apache/kafka/pull/15237
WIP - Built on top of https://github.com/apache/kafka/pull/15221.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and
kirktrue commented on code in PR #15186:
URL: https://github.com/apache/kafka/pull/15186#discussion_r1459293494
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -376,25 +376,21 @@ protected Map
prepareCloseFetchSessi
final
jolshan commented on code in PR #15183:
URL: https://github.com/apache/kafka/pull/15183#discussion_r1459300270
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetAndMetadata.java:
##
@@ -92,30 +117,34 @@ public boolean equals(Object o) {
Offse
[
https://issues.apache.org/jira/browse/KAFKA-16169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808735#comment-17808735
]
Lucas Brutschy commented on KAFKA-16169:
Sound good! I'd suggest doing it after
jolshan commented on PR #15183:
URL: https://github.com/apache/kafka/pull/15183#issuecomment-1900735439
> we could delete all the pending transactional offsets when a new offset
record is replayed.
Hmmm does this work for LSO correctly? I know that the consumer offset topic
has sligh
jsancio commented on code in PR #15235:
URL: https://github.com/apache/kafka/pull/15235#discussion_r1459322086
##
raft/src/main/java/org/apache/kafka/raft/LeaderState.java:
##
@@ -101,6 +101,10 @@ protected LeaderState(
* @return the remainingMs before the checkQuorumTimer
Apoorv Mittal created KAFKA-16172:
-
Summary: Flaky test: testProducerConsumerOverrideLowerQuota –
kafka.api.UserQuotaTest
Key: KAFKA-16172
URL: https://issues.apache.org/jira/browse/KAFKA-16172
Projec
Apoorv Mittal created KAFKA-16173:
-
Summary: Flaky test: testTimeoutMetrics –
org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest
Key: KAFKA-16173
URL: https://issues.apache.org/jira/browse/KAFKA-16
Apoorv Mittal created KAFKA-16174:
-
Summary: Flaky test: testDescribeQuorumStatusSuccessful –
org.apache.kafka.tools.MetadataQuorumCommandTest
Key: KAFKA-16174
URL: https://issues.apache.org/jira/browse/KAFKA-1617
Apoorv Mittal created KAFKA-16175:
-
Summary: Flaky test:
testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads –
kafka.api.SslAdminIntegrationTest
Key: KAFKA-16175
URL: https://issues.apache.org/jira/browse
[
https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808653#comment-17808653
]
Francois Visconte edited comment on KAFKA-15776 at 1/19/24 4:52 PM:
--
Apoorv Mittal created KAFKA-16177:
-
Summary: Flaky test: testBatchSizeZeroNoPartitionNoRecordKey –
kafka.api.PlaintextProducerSendTest
Key: KAFKA-16177
URL: https://issues.apache.org/jira/browse/KAFKA-16177
Apoorv Mittal created KAFKA-16176:
-
Summary: Flaky test:
testSendToPartitionWithFollowerShutdownShouldNotTimeout –
kafka.api.PlaintextProducerSendTest
Key: KAFKA-16176
URL: https://issues.apache.org/jira/browse/K
[
https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808653#comment-17808653
]
Francois Visconte edited comment on KAFKA-15776 at 1/19/24 4:52 PM:
--
apoorvmittal10 commented on PR #15190:
URL: https://github.com/apache/kafka/pull/15190#issuecomment-1900762271
> @apoorvmittal10 : Thanks for the updated PR. LGTM. Are the test failures
related? Are they all being tracked?
@junrao The tests failures are unrelated and below are the det
apoorvmittal10 commented on code in PR #15234:
URL: https://github.com/apache/kafka/pull/15234#discussion_r1459350997
##
server/src/test/java/org/apache/kafka/server/ClientMetricsManagerTest.java:
##
@@ -919,4 +922,101 @@ public void
testPushTelemetryConcurrentRequestAfterSubsc
apoorvmittal10 commented on code in PR #15234:
URL: https://github.com/apache/kafka/pull/15234#discussion_r1459368565
##
server/src/test/java/org/apache/kafka/server/ClientMetricsManagerTest.java:
##
@@ -919,4 +922,101 @@ public void
testPushTelemetryConcurrentRequestAfterSubsc
apoorvmittal10 commented on code in PR #15234:
URL: https://github.com/apache/kafka/pull/15234#discussion_r1459376549
##
server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java:
##
@@ -433,4 +459,26 @@ public Map matchPattern() {
return matchPattern;
AndrewJSchofield commented on code in PR #15234:
URL: https://github.com/apache/kafka/pull/15234#discussion_r1459379766
##
server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java:
##
@@ -433,4 +459,26 @@ public Map matchPattern() {
return matchPattern
mjsax merged PR #15217:
URL: https://github.com/apache/kafka/pull/15217
--
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
mjsax commented on PR #15217:
URL: https://github.com/apache/kafka/pull/15217#issuecomment-1900804744
Merged to `trunk` and cherry-picked to `3.7` branch.
--
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
cmccabe commented on code in PR #15193:
URL: https://github.com/apache/kafka/pull/15193#discussion_r1459430540
##
docs/ops.html:
##
@@ -3992,6 +3979,75 @@ Finalizing the migration
# Other configs ...
+ Reverting to ZooKeeper mode During the Migration
+
+While the clu
cmccabe commented on code in PR #15193:
URL: https://github.com/apache/kafka/pull/15193#discussion_r1459434002
##
docs/ops.html:
##
@@ -3992,6 +3979,75 @@ Finalizing the migration
# Other configs ...
+ Reverting to ZooKeeper mode During the Migration
+
+While the clu
cmccabe commented on code in PR #15193:
URL: https://github.com/apache/kafka/pull/15193#discussion_r1459466608
##
docs/ops.html:
##
@@ -3992,6 +3979,75 @@ Finalizing the migration
# Other configs ...
+ Reverting to ZooKeeper mode During the Migration
+
+While the clu
cmccabe commented on code in PR #15193:
URL: https://github.com/apache/kafka/pull/15193#discussion_r1459430540
##
docs/ops.html:
##
@@ -3992,6 +3979,75 @@ Finalizing the migration
# Other configs ...
+ Reverting to ZooKeeper mode During the Migration
+
+While the clu
cmccabe commented on code in PR #15193:
URL: https://github.com/apache/kafka/pull/15193#discussion_r1459483045
##
docs/ops.html:
##
@@ -3992,6 +3979,75 @@ Finalizing the migration
# Other configs ...
+ Reverting to ZooKeeper mode During the Migration
+
+While the clu
cmccabe commented on code in PR #15193:
URL: https://github.com/apache/kafka/pull/15193#discussion_r1459484260
##
docs/ops.html:
##
@@ -3992,6 +3979,75 @@ Finalizing the migration
# Other configs ...
+ Reverting to ZooKeeper mode During the Migration
+
+While the clu
cmccabe commented on code in PR #15193:
URL: https://github.com/apache/kafka/pull/15193#discussion_r1459484761
##
docs/ops.html:
##
@@ -3992,6 +3979,75 @@ Finalizing the migration
# Other configs ...
+ Reverting to ZooKeeper mode During the Migration
+
+While the clu
cmccabe commented on code in PR #15193:
URL: https://github.com/apache/kafka/pull/15193#discussion_r1459486416
##
docs/ops.html:
##
@@ -3992,6 +3979,75 @@ Finalizing the migration
# Other configs ...
+ Reverting to ZooKeeper mode During the Migration
+
+While the clu
jolshan commented on code in PR #15212:
URL: https://github.com/apache/kafka/pull/15212#discussion_r1459490703
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroup.java:
##
@@ -875,30 +875,43 @@ private void maybeRemovePartitionEpoch(
rreddy-22 commented on code in PR #15211:
URL: https://github.com/apache/kafka/pull/15211#discussion_r1459497325
##
clients/src/main/java/org/apache/kafka/common/ConsumerGroupState.java:
##
@@ -31,7 +31,15 @@ public enum ConsumerGroupState {
COMPLETING_REBALANCE("Completing
rreddy-22 commented on code in PR #15211:
URL: https://github.com/apache/kafka/pull/15211#discussion_r1459497325
##
clients/src/main/java/org/apache/kafka/common/ConsumerGroupState.java:
##
@@ -31,7 +31,15 @@ public enum ConsumerGroupState {
COMPLETING_REBALANCE("Completing
junrao commented on PR #15190:
URL: https://github.com/apache/kafka/pull/15190#issuecomment-1900901612
Thanks for triaging the test failures, @apoorvmittal10. Merging the PR now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
junrao merged PR #15190:
URL: https://github.com/apache/kafka/pull/15190
--
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
1 - 100 of 141 matches
Mail list logo
