[GitHub] [kafka] dengziming commented on pull request #9577: KAFKA-9837: KIP-589 new RPC for notifying controller log dir failure

dengziming commented on PR #9577: URL: https://github.com/apache/kafka/pull/9577#issuecomment-1236593661 go to KIP-858 -- 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 un

[GitHub] [kafka] dengziming closed pull request #9577: KAFKA-9837: KIP-589 new RPC for notifying controller log dir failure

dengziming closed pull request #9577: KAFKA-9837: KIP-589 new RPC for notifying controller log dir failure URL: https://github.com/apache/kafka/pull/9577 -- 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

[jira] [Assigned] (KAFKA-14165) ConfigTransformer.DEFAULT_PATTERN fails on Windows platform

[ https://issues.apache.org/jira/browse/KAFKA-14165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prem Kamal reassigned KAFKA-14165: -- Assignee: (was: Prem Kamal) > ConfigTransformer.DEFAULT_PATTERN fails on Windows platform

[GitHub] [kafka] nizhikov commented on a diff in pull request #12574: KAFKA-13908 Rethrow ExecutionException to preserve original cause

nizhikov commented on code in PR #12574: URL: https://github.com/apache/kafka/pull/12574#discussion_r962507630 ## core/src/main/scala/kafka/server/BrokerServer.scala: ## @@ -448,6 +448,7 @@ class BrokerServer( try { metadataListener.startPublishing(metadataPublis

[GitHub] [kafka] nizhikov commented on a diff in pull request #12574: KAFKA-13908 Rethrow ExecutionException to preserve original cause

nizhikov commented on code in PR #12574: URL: https://github.com/apache/kafka/pull/12574#discussion_r962504857 ## core/src/main/scala/kafka/server/BrokerServer.scala: ## @@ -448,6 +448,7 @@ class BrokerServer( try { metadataListener.startPublishing(metadataPublis

[jira] [Resolved] (KAFKA-10440) MM2 using Kconnect Framework Creates topics recursively on source cluster

[ https://issues.apache.org/jira/browse/KAFKA-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nandini Anagondi resolved KAFKA-10440. -- Resolution: Invalid > MM2 using Kconnect Framework Creates topics recursively on sourc

[jira] [Updated] (KAFKA-14196) Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Description: Several flaky tests under OffsetValidationTest are indicating potential consumer dupli

[jira] [Updated] (KAFKA-14196) Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Labels: new-consumer-threading-should-fix (was: ) > Duplicated consumption during rebalance, causin

[jira] [Updated] (KAFKA-14196) Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Description: Several flaky tests under OffsetValidationTest are indicating potential consumer dupli

[jira] [Updated] (KAFKA-14196) Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Description: Several flaky tests under OffsetValidationTest are indicating potential consumer dupli

[jira] [Updated] (KAFKA-14196) Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Description: Several flaky tests under OffsetValidationTest are indicating potential consumer dupli

[jira] [Commented] (KAFKA-14130) Reduce RackAwarenessIntegrationTest to a unit test

[ https://issues.apache.org/jira/browse/KAFKA-14130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600190#comment-17600190 ] Guozhang Wang commented on KAFKA-14130: --- Hello [~hoping][~Eslam.hamdy] sorry about

[jira] [Resolved] (KAFKA-14130) Reduce RackAwarenessIntegrationTest to a unit test

[ https://issues.apache.org/jira/browse/KAFKA-14130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-14130. --- Fix Version/s: 3.4.0 Assignee: Guozhang Wang (was: Eslam) Resolution: Fixed

[jira] [Updated] (KAFKA-14196) Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Affects Version/s: 3.3.0 > Duplicated consumption during rebalance, causing OffsetValidationTest to

[jira] [Updated] (KAFKA-14196) Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Summary: Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky (was: F

[jira] [Updated] (KAFKA-14196) Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Affects Version/s: 3.2.1 > Duplicated consumption during rebalance, causing OffsetValidationTest to

[jira] [Updated] (KAFKA-14196) Flaky OffsetValidationTest seems to indicate potential duplication issue during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Description: Several flaky tests under OffsetValidationTest are indicating potential consumer dupli

[jira] (KAFKA-14196) Flaky OffsetValidationTest seems to indicate potential duplication issue during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14196 ] Philip Nee deleted comment on KAFKA-14196: was (Author: JIRAUSER283568): I guess it should be related to KAFKA-4689 Looking at the coordinator code, I'm not entirely sure if the commented s

[jira] (KAFKA-14196) Flaky OffsetValidationTest seems to indicate potential duplication issue during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14196 ] Philip Nee deleted comment on KAFKA-14196: was (Author: JIRAUSER283568): I'm tracing the code path, it seems like the poll() continues to happen during the rebalance process; however, no com

[jira] [Updated] (KAFKA-14196) Flaky OffsetValidationTest seems to indicate potential duplication issue during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Description: Several flaky tests under OffsetValidationTest are indicating potential consumer dupli

[jira] [Updated] (KAFKA-14196) Flaky OffsetValidationTest seems to indicate potential duplication issue during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Description: Several flaky tests under OffsetValidationTest are indicating potential consumer dupli

[jira] [Updated] (KAFKA-14196) Flaky OffsetValidationTest seems to indicate potential duplication issue during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Affects Version/s: (was: 3.2.1) > Flaky OffsetValidationTest seems to indicate potential duplica

[jira] [Updated] (KAFKA-14196) Flaky OffsetValidationTest seems to indicate potential duplication issue during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Description: Several flaky tests under OffsetValidationTest are indicating potential consumer dupli

[jira] [Updated] (KAFKA-14196) Flaky OffsetValidationTest seems to indicate potential duplication issue during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philip Nee updated KAFKA-14196: --- Description: Several flaky tests under OffsetValidationTest are indicating potential consumer dupli

[jira] [Commented] (KAFKA-14196) Flaky OffsetValidationTest seems to indicate potential duplication issue during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600166#comment-17600166 ] Philip Nee commented on KAFKA-14196: If I understand this correctly: Seems like this

[GitHub] [kafka] showuon commented on a diff in pull request #12574: KAFKA-13908 Rethrow ExecutionException to preserve original cause

showuon commented on code in PR #12574: URL: https://github.com/apache/kafka/pull/12574#discussion_r962432424 ## core/src/main/scala/kafka/server/BrokerServer.scala: ## @@ -448,6 +448,7 @@ class BrokerServer( try { metadataListener.startPublishing(metadataPublish

[GitHub] [kafka] vvcephei commented on a diff in pull request #12020: KAFKA-13818: Add generation to consumer assignor logs

vvcephei commented on code in PR #12020: URL: https://github.com/apache/kafka/pull/12020#discussion_r962326811 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java: ## @@ -164,13 +166,23 @@ public ConsumerCoordinator(GroupRebalanceConfig

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

vamossagar12 commented on code in PR #12561: URL: https://github.com/apache/kafka/pull/12561#discussion_r962289380 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java: ## @@ -285,18 +292,13 @@ ClusterAssignment perfor

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

vamossagar12 commented on code in PR #12561: URL: https://github.com/apache/kafka/pull/12561#discussion_r962289115 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java: ## @@ -307,9 +309,31 @@ ClusterAssignment perform

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

vamossagar12 commented on code in PR #12561: URL: https://github.com/apache/kafka/pull/12561#discussion_r962289115 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java: ## @@ -307,9 +309,31 @@ ClusterAssignment perform

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

vamossagar12 commented on code in PR #12561: URL: https://github.com/apache/kafka/pull/12561#discussion_r962288821 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java: ## @@ -307,9 +309,31 @@ ClusterAssignment perform

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

vamossagar12 commented on code in PR #12561: URL: https://github.com/apache/kafka/pull/12561#discussion_r962288729 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java: ## @@ -285,18 +292,13 @@ ClusterAssignment perfor

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

vamossagar12 commented on code in PR #12561: URL: https://github.com/apache/kafka/pull/12561#discussion_r962288306 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java: ## @@ -118,6 +119,93 @@ public void testTaskA

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

vamossagar12 commented on code in PR #12561: URL: https://github.com/apache/kafka/pull/12561#discussion_r962288275 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java: ## @@ -307,9 +309,31 @@ ClusterAssignment perform

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

vamossagar12 commented on code in PR #12561: URL: https://github.com/apache/kafka/pull/12561#discussion_r962288239 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java: ## @@ -65,26 +67,32 @@ public class IncrementalCo