[GitHub] [kafka] showuon commented on a diff in pull request #14355: KAFKA-14595 ReassignPartitionsUnitTest rewritten in java

showuon commented on code in PR #14355: URL: https://github.com/apache/kafka/pull/14355#discussion_r1333917895 ## tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsUnitTest.java: ## @@ -0,0 +1,790 @@ +/* + * Licensed to the Apache Software Foundation (ASF) un

[jira] [Commented] (KAFKA-15414) remote logs get deleted after partition reassignment

[ https://issues.apache.org/jira/browse/KAFKA-15414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767850#comment-17767850 ] Francois Visconte commented on KAFKA-15414: --- [~showuon] It's working now with

[GitHub] [kafka] showuon commented on a diff in pull request #14355: KAFKA-14595 ReassignPartitionsUnitTest rewritten in java

showuon commented on code in PR #14355: URL: https://github.com/apache/kafka/pull/14355#discussion_r1333901289 ## tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsUnitTest.java: ## @@ -0,0 +1,790 @@ +/* + * Licensed to the Apache Software Foundation (ASF) un

[jira] [Commented] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767818#comment-17767818 ] Luke Chen commented on KAFKA-15481: --- Thanks for the suggestion! [~ben.manes]! > Concu

[GitHub] [kafka] github-actions[bot] commented on pull request #13315: KAFKA-14767: Fix missing commitId build error after git gc

github-actions[bot] commented on PR #13315: URL: https://github.com/apache/kafka/pull/13315#issuecomment-1730754906 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 ask a committer for review. If the PR has merge

[GitHub] [kafka] kamalcph commented on pull request #14407: KAFKA-15479: Remote log segments should be considered once for retention breach

kamalcph commented on PR #14407: URL: https://github.com/apache/kafka/pull/14407#issuecomment-1730747471 @clolov @divijvaidya @showuon @satishd Test failures are unrelated. Please take another look! -- This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [kafka] philipnee commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

philipnee commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r1333739561 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultEventHandler.java: ## @@ -141,11 +77,25 @@ public T addAndGet(final CompletableApplicati

[GitHub] [kafka] jolshan commented on pull request #14422: test -- ignore

jolshan commented on PR #14422: URL: https://github.com/apache/kafka/pull/14422#issuecomment-1730508946 Looks like we broke the callback timing test, but the tests otherwise looked better. I will rerun -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] CalvinConfluent commented on a diff in pull request #14417: KAFKA-14519; [1/N] Implement coordinator runtime metrics

CalvinConfluent commented on code in PR #14417: URL: https://github.com/apache/kafka/pull/14417#discussion_r1333694211 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/CoordinatorRuntimeMetrics.java: ## @@ -0,0 +1,244 @@ +/* + * Licensed to the Apach

[GitHub] [kafka] kirktrue commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

kirktrue commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333675817 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberAssignmentReconciler.java: ## @@ -0,0 +1,291 @@ +/* + * Licensed to the Apache Software Foun

[GitHub] [kafka] cmccabe commented on a diff in pull request #14399: KAFKA-15466: Add KIP-919 support for some admin APIs

cmccabe commented on code in PR #14399: URL: https://github.com/apache/kafka/pull/14399#discussion_r1333666762 ## core/src/main/scala/kafka/server/ControllerApis.scala: ## @@ -1028,6 +1028,10 @@ class ControllerApis( def handleDescribeCluster(request: RequestChannel.Request):

[GitHub] [kafka] cmccabe commented on a diff in pull request #14399: KAFKA-15466: Add KIP-919 support for some admin APIs

cmccabe commented on code in PR #14399: URL: https://github.com/apache/kafka/pull/14399#discussion_r1333666076 ## clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java: ## @@ -4009,12 +4134,11 @@ void handleFailure(Throwable throwable) { @Override

[GitHub] [kafka] kirktrue commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

kirktrue commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333659148 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableBackgroundEvent.java: ## @@ -0,0 +1,86 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [kafka] kirktrue commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

kirktrue commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333657687 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -237,4 +253,64 @@ public void updateAssignment(ConsumerGroupHea

[GitHub] [kafka] kirktrue commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

kirktrue commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333654590 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberAssignmentReconciler.java: ## @@ -0,0 +1,291 @@ +/* + * Licensed to the Apache Software Foun

[GitHub] [kafka] lianetm commented on a diff in pull request #14364: KAFKA-15278: Implement HeartbeatRequestManager to handle heartbeat requests

lianetm commented on code in PR #14364: URL: https://github.com/apache/kafka/pull/14364#discussion_r1333629206 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java: ## @@ -0,0 +1,287 @@ +/* + * Licensed to the Apache Software Foundati

[GitHub] [kafka] lianetm commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

lianetm commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333628852 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -237,4 +253,64 @@ public void updateAssignment(ConsumerGroupHear

[GitHub] [kafka] lianetm commented on a diff in pull request #14364: KAFKA-15278: Implement HeartbeatRequestManager to handle heartbeat requests

lianetm commented on code in PR #14364: URL: https://github.com/apache/kafka/pull/14364#discussion_r1333624789 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/AssignorSelection.java: ## @@ -79,6 +80,9 @@ public int hashCode() { @Override public S

[GitHub] [kafka] lianetm commented on a diff in pull request #14364: KAFKA-15278: Implement HeartbeatRequestManager to handle heartbeat requests

lianetm commented on code in PR #14364: URL: https://github.com/apache/kafka/pull/14364#discussion_r1333624789 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/AssignorSelection.java: ## @@ -79,6 +80,9 @@ public int hashCode() { @Override public S

[GitHub] [kafka] jeffkbkim commented on a diff in pull request #14408: KAFKA-14506: Implement DeleteGroups API and OffsetDelete API

jeffkbkim commented on code in PR #14408: URL: https://github.com/apache/kafka/pull/14408#discussion_r1333554676 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java: ## @@ -523,9 +526,63 @@ public CompletableFuture> groupsByTopicPa

[GitHub] [kafka] lianetm commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

lianetm commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r1333620613 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultEventHandler.java: ## @@ -141,11 +77,25 @@ public T addAndGet(final CompletableApplication

[GitHub] [kafka] lianetm commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

lianetm commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r1333617066 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java: ## @@ -259,17 +144,41 @@ long handlePollResult(NetworkClientDelegate.

[GitHub] [kafka] philipnee commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

philipnee commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r1333616692 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java: ## @@ -259,17 +144,41 @@ long handlePollResult(NetworkClientDelegat

[GitHub] [kafka] lianetm commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

lianetm commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r1333613388 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java: ## @@ -217,29 +98,33 @@ public void run() { } }

[GitHub] [kafka] lianetm commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

lianetm commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r1333605133 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java: ## @@ -16,197 +16,78 @@ */ package org.apache.kafka.clients.consum

[GitHub] [kafka] lianetm commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

lianetm commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r1333599432 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java: ## @@ -16,197 +16,78 @@ */ package org.apache.kafka.clients.consum

[GitHub] [kafka] lianetm commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

lianetm commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333583458 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -237,4 +253,64 @@ public void updateAssignment(ConsumerGroupHear

[GitHub] [kafka] tooptoop4 commented on pull request #14192: MINOR: improve info log for memberIDRequired exception

tooptoop4 commented on PR #14192: URL: https://github.com/apache/kafka/pull/14192#issuecomment-1730273682 🦗 -- 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,

[GitHub] [kafka] lianetm commented on pull request #14413: KAFKA-15275 [2/N]: Client state machine improvements

lianetm commented on PR #14413: URL: https://github.com/apache/kafka/pull/14413#issuecomment-1730248257 Thanks for the review @kirktrue! All comments addressed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14417: KAFKA-14519; [1/N] Implement coordinator runtime metrics

rreddy-22 commented on code in PR #14417: URL: https://github.com/apache/kafka/pull/14417#discussion_r199585 ## core/src/test/scala/unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala: ## @@ -283,7 +292,61 @@ class CoordinatorLoaderImplTest { minOneMessage

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14417: KAFKA-14519; [1/N] Implement coordinator runtime metrics

rreddy-22 commented on code in PR #14417: URL: https://github.com/apache/kafka/pull/14417#discussion_r1333554128 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/CoordinatorRuntimeMetrics.java: ## @@ -0,0 +1,244 @@ +/* + * Licensed to the Apache Soft

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14417: KAFKA-14519; [1/N] Implement coordinator runtime metrics

rreddy-22 commented on code in PR #14417: URL: https://github.com/apache/kafka/pull/14417#discussion_r1333553371 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/CoordinatorRuntimeMetrics.java: ## @@ -0,0 +1,244 @@ +/* + * Licensed to the Apache Soft

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14417: KAFKA-14519; [1/N] Implement coordinator runtime metrics

rreddy-22 commented on code in PR #14417: URL: https://github.com/apache/kafka/pull/14417#discussion_r1333553371 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/CoordinatorRuntimeMetrics.java: ## @@ -0,0 +1,244 @@ +/* + * Licensed to the Apache Soft

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14418: MINOR: Move TopicIdPartition class to server-common

rreddy-22 commented on code in PR #14418: URL: https://github.com/apache/kafka/pull/14418#discussion_r1333546302 ## server-common/src/main/java/org/apache/kafka/server/common/TopicIdPartition.java: ## @@ -14,43 +14,62 @@ * See the License for the specific language governing pe

[GitHub] [kafka] CalvinConfluent commented on a diff in pull request #14053: KAFKA-15221; Fix the race between fetch requests from a rebooted follower.

CalvinConfluent commented on code in PR #14053: URL: https://github.com/apache/kafka/pull/14053#discussion_r1333490449 ## core/src/main/scala/kafka/cluster/Replica.scala: ## @@ -98,14 +103,20 @@ class Replica(val brokerId: Int, val topicPartition: TopicPartition) extends Log

[jira] [Commented] (KAFKA-15483) Update metrics documentation for the new metrics implemented as part of KIP-938

[ https://issues.apache.org/jira/browse/KAFKA-15483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767689#comment-17767689 ] ASF GitHub Bot commented on KAFKA-15483: mumrah commented on PR #548: URL: https

[GitHub] [kafka] mumrah commented on a diff in pull request #14399: KAFKA-15466: Add KIP-919 support for some admin APIs

mumrah commented on code in PR #14399: URL: https://github.com/apache/kafka/pull/14399#discussion_r1333463150 ## clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java: ## @@ -4009,12 +4134,11 @@ void handleFailure(Throwable throwable) { @Override

[GitHub] [kafka] dajac opened a new pull request, #14422: test -- ignore

dajac opened a new pull request, #14422: URL: https://github.com/apache/kafka/pull/14422 *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 testing s

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14417: KAFKA-14519; [1/N] Implement coordinator runtime metrics

rreddy-22 commented on code in PR #14417: URL: https://github.com/apache/kafka/pull/14417#discussion_r1333402026 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/CoordinatorRuntimeMetrics.java: ## @@ -0,0 +1,244 @@ +/* + * Licensed to the Apache Soft

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14417: KAFKA-14519; [1/N] Implement coordinator runtime metrics

rreddy-22 commented on code in PR #14417: URL: https://github.com/apache/kafka/pull/14417#discussion_r1333402026 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/CoordinatorRuntimeMetrics.java: ## @@ -0,0 +1,244 @@ +/* + * Licensed to the Apache Soft

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14417: KAFKA-14519; [1/N] Implement coordinator runtime metrics

rreddy-22 commented on code in PR #14417: URL: https://github.com/apache/kafka/pull/14417#discussion_r199585 ## core/src/test/scala/unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala: ## @@ -283,7 +292,61 @@ class CoordinatorLoaderImplTest { minOneMessage

[jira] [Commented] (KAFKA-15483) Update metrics documentation for the new metrics implemented as part of KIP-938

[ https://issues.apache.org/jira/browse/KAFKA-15483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767651#comment-17767651 ] ASF GitHub Bot commented on KAFKA-15483: satishd commented on PR #548: URL: http

[jira] [Commented] (KAFKA-15483) Update metrics documentation for the new metrics implemented as part of KIP-938

[ https://issues.apache.org/jira/browse/KAFKA-15483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767650#comment-17767650 ] ASF GitHub Bot commented on KAFKA-15483: satishd commented on code in PR #548: U

[GitHub] [kafka] lihaosky closed pull request #13846: KAFKA-15022: [1/N] add configs to control rack aware assignment

lihaosky closed pull request #13846: KAFKA-15022: [1/N] add configs to control rack aware assignment URL: https://github.com/apache/kafka/pull/13846 -- 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 t

[jira] [Commented] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767645#comment-17767645 ] Ben Manes commented on KAFKA-15481: --- Excellent investigation! You are correct, using a

[GitHub] [kafka] divijvaidya commented on pull request #14419: MINOR: Fix kafka-site formatting

divijvaidya commented on PR #14419: URL: https://github.com/apache/kafka/pull/14419#issuecomment-1729951729 > @divijvaidya Don't forget to do this same change under `kafka-site` as well. Thank you for the reminder. TBH I had forgot about it 😳 Created the PR at https://github.c

[GitHub] [kafka] philipnee commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

philipnee commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r155626 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/BackgroundEventProcessor.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [kafka] philipnee commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

philipnee commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r153596 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java: ## @@ -79,6 +100,7 @@ public void clearBufferedDataForUnassignedPartitions(Collect

[GitHub] [kafka] philipnee commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

philipnee commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r153029 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchRequestManager.java: ## @@ -0,0 +1,136 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Assigned] (KAFKA-15169) Add tests for RemoteIndexCache

[ https://issues.apache.org/jira/browse/KAFKA-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arpit Goyal reassigned KAFKA-15169: --- Assignee: Arpit Goyal (was: Lan Ding) > Add tests for RemoteIndexCache > -

[jira] [Commented] (KAFKA-15169) Add tests for RemoteIndexCache

[ https://issues.apache.org/jira/browse/KAFKA-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767639#comment-17767639 ] Arpit Goyal commented on KAFKA-15169: - [~divijvaidya] [~isding_l] [~satish.duggana]

[GitHub] [kafka] philipnee commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

philipnee commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r149057 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/ErrorEventHandler.java: ## @@ -22,13 +22,18 @@ import java.util.Queue; public class ErrorEven

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14408: KAFKA-14506: Implement DeleteGroups API and OffsetDelete API

rreddy-22 commented on code in PR #14408: URL: https://github.com/apache/kafka/pull/14408#discussion_r148886 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java: ## @@ -90,4 +90,29 @@ void validateOffsetFetch( int memberEpoch, l

[GitHub] [kafka] philipnee commented on a diff in pull request #14406: KAFKA-14274 [6, 7]: Introduction of fetch request manager

philipnee commented on code in PR #14406: URL: https://github.com/apache/kafka/pull/14406#discussion_r145949 ## checkstyle/import-control.xml: ## @@ -205,6 +205,10 @@ + Review Comment: is the extra line intentional? -- This is an automated message fro

[jira] [Created] (KAFKA-15484) Implement general uniform broker side assignor

Ritika Muduganti created KAFKA-15484: Summary: Implement general uniform broker side assignor Key: KAFKA-15484 URL: https://issues.apache.org/jira/browse/KAFKA-15484 Project: Kafka Issue

[jira] [Updated] (KAFKA-14515) Implement optimized uniform broker side assignor

[ https://issues.apache.org/jira/browse/KAFKA-14515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ritika Muduganti updated KAFKA-14515: - Summary: Implement optimized uniform broker side assignor (was: Implement uniform broke

[jira] [Assigned] (KAFKA-15483) Update metrics documentation for the new metrics implemented as part of KIP-938

[ https://issues.apache.org/jira/browse/KAFKA-15483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana reassigned KAFKA-15483: -- Assignee: David Arthur > Update metrics documentation for the new metrics implemented

[jira] [Commented] (KAFKA-15483) Update metrics documentation for the new metrics implemented as part of KIP-938

[ https://issues.apache.org/jira/browse/KAFKA-15483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767638#comment-17767638 ] Satish Duggana commented on KAFKA-15483: [~mumrah] Assigning it to you as you ra

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14408: KAFKA-14506: Implement DeleteGroups API and OffsetDelete API

rreddy-22 commented on code in PR #14408: URL: https://github.com/apache/kafka/pull/14408#discussion_r131492 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/generic/GenericGroup.java: ## @@ -849,6 +853,46 @@ public void validateOffsetFetch( }

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14408: KAFKA-14506: Implement DeleteGroups API and OffsetDelete API

rreddy-22 commented on code in PR #14408: URL: https://github.com/apache/kafka/pull/14408#discussion_r129945 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java: ## @@ -262,6 +267,45 @@ public HeartbeatResponseData genericGroupHea

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14408: KAFKA-14506: Implement DeleteGroups API and OffsetDelete API

rreddy-22 commented on code in PR #14408: URL: https://github.com/apache/kafka/pull/14408#discussion_r127696 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java: ## @@ -90,4 +90,29 @@ void validateOffsetFetch( int memberEpoch, l

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14408: KAFKA-14506: Implement DeleteGroups API and OffsetDelete API

rreddy-22 commented on code in PR #14408: URL: https://github.com/apache/kafka/pull/14408#discussion_r127696 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java: ## @@ -90,4 +90,29 @@ void validateOffsetFetch( int memberEpoch, l

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14408: KAFKA-14506: Implement DeleteGroups API and OffsetDelete API

rreddy-22 commented on code in PR #14408: URL: https://github.com/apache/kafka/pull/14408#discussion_r126880 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java: ## @@ -90,4 +90,29 @@ void validateOffsetFetch( int memberEpoch, l

[GitHub] [kafka] lianetm commented on a diff in pull request #14413: KAFKA-15275 [2/N]: Client state machine improvements

lianetm commented on code in PR #14413: URL: https://github.com/apache/kafka/pull/14413#discussion_r124044 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -19,56 +19,91 @@ import org.apache.kafka.common.message.Consum

[GitHub] [kafka] lianetm commented on a diff in pull request #14413: KAFKA-15275 [2/N]: Client state machine improvements

lianetm commented on code in PR #14413: URL: https://github.com/apache/kafka/pull/14413#discussion_r121553 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -19,56 +19,91 @@ import org.apache.kafka.common.message.Consum

[GitHub] [kafka] lianetm commented on a diff in pull request #14413: KAFKA-15275 [2/N]: Client state machine improvements

lianetm commented on code in PR #14413: URL: https://github.com/apache/kafka/pull/14413#discussion_r114252 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -19,56 +19,91 @@ import org.apache.kafka.common.message.Consum

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14418: MINOR: Move TopicIdPartition class to server-common

rreddy-22 commented on code in PR #14418: URL: https://github.com/apache/kafka/pull/14418#discussion_r100713 ## server-common/src/main/java/org/apache/kafka/server/common/TopicIdPartition.java: ## @@ -14,43 +14,62 @@ * See the License for the specific language governing pe

[GitHub] [kafka] rreddy-22 commented on a diff in pull request #14418: MINOR: Move TopicIdPartition class to server-common

rreddy-22 commented on code in PR #14418: URL: https://github.com/apache/kafka/pull/14418#discussion_r1333298950 ## server-common/src/main/java/org/apache/kafka/server/common/TopicIdPartition.java: ## @@ -14,43 +14,62 @@ * See the License for the specific language governing pe

[jira] [Resolved] (KAFKA-14960) Metadata Request Manager and listTopics/partitionsFor API

[ https://issues.apache.org/jira/browse/KAFKA-14960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14960. - Fix Version/s: 3.7.0 Resolution: Fixed merged the PR to trunk. > Metadata Request Manager and li

[GitHub] [kafka] junrao merged pull request #14386: KAFKA-14960: TopicMetadata request manager

junrao merged PR #14386: URL: https://github.com/apache/kafka/pull/14386 -- 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

[GitHub] [kafka] lianetm commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

lianetm commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333212830 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -237,4 +253,64 @@ public void updateAssignment(ConsumerGroupHear

[GitHub] [kafka] lianetm commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

lianetm commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333187091 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -237,4 +253,64 @@ public void updateAssignment(ConsumerGroupHear

[GitHub] [kafka] lianetm commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

lianetm commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333166590 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java: ## @@ -237,4 +253,64 @@ public void updateAssignment(ConsumerGroupHear

[GitHub] [kafka] dajac commented on a diff in pull request #14408: KAFKA-14506: Implement DeleteGroups API and OffsetDelete API

dajac commented on code in PR #14408: URL: https://github.com/apache/kafka/pull/14408#discussion_r1333162337 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/generic/GenericGroup.java: ## @@ -849,6 +853,46 @@ public void validateOffsetFetch( }

[GitHub] [kafka] lianetm commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

lianetm commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333144301 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberAssignmentReconciler.java: ## @@ -0,0 +1,291 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [kafka] jolshan commented on pull request #14402: MINOR: Push logic to resolve the transaction coordinator into the AddPartitionsToTxnManager

jolshan commented on PR #14402: URL: https://github.com/apache/kafka/pull/14402#issuecomment-1729672777 Maybe we should file a JIRA to investigate. 😅 -- 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

[GitHub] [kafka] mumrah opened a new pull request, #14421: MINOR Add KIP-938 metrics to bundled docs

mumrah opened a new pull request, #14421: URL: https://github.com/apache/kafka/pull/14421 (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-mai

[GitHub] [kafka] lianetm commented on a diff in pull request #14357: KAFKA-15276: Implement partition assignment reconciliation

lianetm commented on code in PR #14357: URL: https://github.com/apache/kafka/pull/14357#discussion_r1333122605 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberAssignmentReconciler.java: ## @@ -0,0 +1,291 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [kafka] Nickstery opened a new pull request, #14420: KAFKA-15480 | Add RemoteStorageInterruptedException plugin controlled…

Nickstery opened a new pull request, #14420: URL: https://github.com/apache/kafka/pull/14420 Exception allows the plugin to notify Kafka an API operation in progress was interrupted as a result of task cancellation, which can happen under changes such as leadership migration or topic deleti

[GitHub] [kafka] dajac commented on a diff in pull request #14418: MINOR: Move TopicIdPartition class to server-common

dajac commented on code in PR #14418: URL: https://github.com/apache/kafka/pull/14418#discussion_r1333051894 ## server-common/src/main/java/org/apache/kafka/server/common/TopicIdPartition.java: ## @@ -14,43 +14,62 @@ * See the License for the specific language governing permis

[jira] (KAFKA-15417) JoinWindow does not seem to work properly with a KStream - KStream - LeftJoin()

[ https://issues.apache.org/jira/browse/KAFKA-15417 ] Victor van den Hoven deleted comment on KAFKA-15417: -- was (Author: victorvandenhoven): The before/after for the joinSpuriousLookBackTimeMs in the left/right join node were flipped i

[GitHub] [kafka] dajac commented on pull request #14402: MINOR: Push logic to resolve the transaction coordinator into the AddPartitionsToTxnManager

dajac commented on PR #14402: URL: https://github.com/apache/kafka/pull/14402#issuecomment-1729476773 @jolshan I just found similar failures in another PR: https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14418/1/tests. That seems to indicate that the issue

[GitHub] [kafka] Vaibhav-Nazare commented on pull request #13817: KAFKA-15062: Adding ppc64le build stage

Vaibhav-Nazare commented on PR #13817: URL: https://github.com/apache/kafka/pull/13817#issuecomment-1729435287 Hi Team, can we look into this PR as the KIP-942 has been adopted -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [kafka] yashmayya commented on a diff in pull request #14412: KAFKA-14133: Move MeteredTimestampedKeyValueStoreTest, ReadOnlyWindowStoreFacadeTest and TimestampedWindowStoreBuilderTest to Moc

yashmayya commented on code in PR #14412: URL: https://github.com/apache/kafka/pull/14412#discussion_r1332848023 ## streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilderTest.java: ## @@ -223,38 +208,9 @@ public void shouldThrowNullPointerIf

[jira] [Commented] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767490#comment-17767490 ] Divij Vaidya commented on KAFKA-15481: -- [~ben.manes] your expert thoughts on best w

[jira] [Comment Edited] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767489#comment-17767489 ] Divij Vaidya edited comment on KAFKA-15481 at 9/21/23 10:05 AM: --

[jira] [Commented] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767489#comment-17767489 ] Divij Vaidya commented on KAFKA-15481: -- > And in `RemoteIndexCache#remove`, we can

[jira] [Comment Edited] (KAFKA-15463) StreamsException: Accessing from an unknown node

[ https://issues.apache.org/jira/browse/KAFKA-15463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767452#comment-17767452 ] Yevgeny edited comment on KAFKA-15463 at 9/21/23 10:00 AM: --- so

[jira] [Commented] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767487#comment-17767487 ] Divij Vaidya commented on KAFKA-15481: -- You are right, but you are assuming that re

[jira] [Commented] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767486#comment-17767486 ] Luke Chen commented on KAFKA-15481: --- After re-reading the suggestion in Caffeine [doc

[jira] [Commented] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767485#comment-17767485 ] Luke Chen commented on KAFKA-15481: --- About the solution to change to sync way, I have

[jira] [Commented] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767484#comment-17767484 ] Divij Vaidya commented on KAFKA-15481: -- > the issue is because we time gap between

[GitHub] [kafka] divijvaidya commented on a diff in pull request #14412: KAFKA-14133: Move MeteredTimestampedKeyValueStoreTest, ReadOnlyWindowStoreFacadeTest and TimestampedWindowStoreBuilderTest to M

divijvaidya commented on code in PR #14412: URL: https://github.com/apache/kafka/pull/14412#discussion_r1332776819 ## streams/src/test/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilderTest.java: ## @@ -223,38 +208,9 @@ public void shouldThrowNullPointer

[jira] [Comment Edited] (KAFKA-15463) StreamsException: Accessing from an unknown node

[ https://issues.apache.org/jira/browse/KAFKA-15463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767452#comment-17767452 ] Yevgeny edited comment on KAFKA-15463 at 9/21/23 9:34 AM: -- some

[GitHub] [kafka] divijvaidya commented on pull request #14419: MINOR: Fix kafka-site formatting

divijvaidya commented on PR #14419: URL: https://github.com/apache/kafka/pull/14419#issuecomment-1729209212 Merged into trunk and `3.6` -- 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 specifi

[GitHub] [kafka] divijvaidya merged pull request #14419: MINOR: Fix kafka-site formatting

divijvaidya merged PR #14419: URL: https://github.com/apache/kafka/pull/14419 -- 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.apa

[jira] [Commented] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767483#comment-17767483 ] Luke Chen commented on KAFKA-15481: --- Nice find, [~divijvaidya]! So, the issue is becau

[GitHub] [kafka] satishd commented on a diff in pull request #14419: MINOR: Fix kafka-site formatting

satishd commented on code in PR #14419: URL: https://github.com/apache/kafka/pull/14419#discussion_r1332742687 ## streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java: ## @@ -777,7 +777,7 @@ public class StreamsConfig extends AbstractConfig { @SuppressWarnings(

[jira] [Commented] (KAFKA-15481) Concurrency bug in RemoteIndexCache leads to IOException

[ https://issues.apache.org/jira/browse/KAFKA-15481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767472#comment-17767472 ] Divij Vaidya commented on KAFKA-15481: -- FYI [~satishd] [~Kamal C] [~christo_lolov]

[jira] [Comment Edited] (KAFKA-15463) StreamsException: Accessing from an unknown node

[ https://issues.apache.org/jira/browse/KAFKA-15463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767452#comment-17767452 ] Yevgeny edited comment on KAFKA-15463 at 9/21/23 8:52 AM: -- some

  1   2   >