[GitHub] [kafka] yashmayya commented on a diff in pull request #12568: KAFKA-14015: StandaloneHerder::restartConnector should reconfigure tasks if configs have been changed

yashmayya commented on code in PR #12568: URL: https://github.com/apache/kafka/pull/12568#discussion_r962112024 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java: ## @@ -812,7 +861,7 @@ public void testPutConnectorConfig() thr

[GitHub] [kafka] yashmayya commented on a diff in pull request #12478: KAFKA-13952 fix RetryWithToleranceOperator to respect infinite retries configuration

yashmayya commented on code in PR #12478: URL: https://github.com/apache/kafka/pull/12478#discussion_r962111245 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java: ## @@ -268,8 +275,12 @@ void backoff(int attempt, long deadli

[GitHub] [kafka] yashmayya commented on a diff in pull request #12478: KAFKA-13952 fix RetryWithToleranceOperator to respect infinite retries configuration

yashmayya commented on code in PR #12478: URL: https://github.com/apache/kafka/pull/12478#discussion_r962110842 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTest.java: ## @@ -199,112 +202,156 @@ private RetryWithToleranceOper

[GitHub] [kafka] yashmayya commented on a diff in pull request #12478: KAFKA-13952 fix RetryWithToleranceOperator to respect infinite retries configuration

yashmayya commented on code in PR #12478: URL: https://github.com/apache/kafka/pull/12478#discussion_r962110802 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTest.java: ## @@ -199,112 +202,156 @@ private RetryWithToleranceOper

[GitHub] [kafka] yashmayya commented on a diff in pull request #12478: KAFKA-13952 fix RetryWithToleranceOperator to respect infinite retries configuration

yashmayya commented on code in PR #12478: URL: https://github.com/apache/kafka/pull/12478#discussion_r962110783 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTest.java: ## @@ -199,112 +202,156 @@ private RetryWithToleranceOper

[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_r962096234 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java: ## @@ -65,26 +67,32 @@ public class IncrementalCo

[GitHub] [kafka] guozhangwang merged pull request #12519: KAFKA-10199: Handle exceptions from state updater

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

[GitHub] [kafka] guozhangwang commented on pull request #12519: KAFKA-10199: Handle exceptions from state updater

guozhangwang commented on PR #12519: URL: https://github.com/apache/kafka/pull/12519#issuecomment-1236007271 Test failures are not relevant. I'm going to merge to trunk. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (KAFKA-14201) Consumer should not send group instance ID if committing with empty member ID

[ https://issues.apache.org/jira/browse/KAFKA-14201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599744#comment-17599744 ] Jason Gustafson commented on KAFKA-14201: - Worth mentioning that the alternative

[jira] [Created] (KAFKA-14201) Consumer should not send group instance ID if committing with empty member ID

Jason Gustafson created KAFKA-14201: --- Summary: Consumer should not send group instance ID if committing with empty member ID Key: KAFKA-14201 URL: https://issues.apache.org/jira/browse/KAFKA-14201 P

[GitHub] [kafka] ijuma opened a new pull request, #12588: MINOR: Enable "abort previous builds" for PRs

ijuma opened a new pull request, #12588: URL: https://github.com/apache/kafka/pull/12588 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade not

[GitHub] [kafka] ijuma commented on a diff in pull request #12587: MINOR: Use named class for ExpiringCredential to improve `principalLogText()` output

ijuma commented on code in PR #12587: URL: https://github.com/apache/kafka/pull/12587#discussion_r962039832 ## clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshingLogin.java: ## @@ -421,17 +419,17 @@ private void reLo

[GitHub] [kafka] ijuma opened a new pull request, #12587: MINOR: Use named class for ExpiringCredential to improve `principalLogText()` output

ijuma opened a new pull request, #12587: URL: https://github.com/apache/kafka/pull/12587 `principalLogText()` outputs the expiring credential simple class name and it's empty for anonymous classes. ### Committer Checklist (excluded from commit message) - [ ] Verify design and imp

[GitHub] [kafka] cmccabe commented on pull request #12586: KAFKA-14200: kafka-features.sh must exit with non-zero error code on error

cmccabe commented on PR #12586: URL: https://github.com/apache/kafka/pull/12586#issuecomment-1235899799 It looks like something in the Streams tests is calling `exit 1`. I will see if this still happens with `Exit.exit` and `Exit.halt` stubbed out. -- This is an automated message from the

[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=17599705#comment-17599705 ] Philip Nee commented on KAFKA-14196: I'm tracing the code path, it seems like the po

[jira] [Assigned] (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 reassigned KAFKA-14196: -- Assignee: Philip Nee > Flaky OffsetValidationTest seems to indicate potential duplication iss

[jira] [Comment Edited] (KAFKA-14172) bug: State stores lose state when tasks are reassigned under EOS wit…

[ https://issues.apache.org/jira/browse/KAFKA-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599478#comment-17599478 ] John Gray edited comment on KAFKA-14172 at 9/2/22 5:58 PM: --- [~

[jira] [Updated] (KAFKA-14200) kafka-features.sh must exit with non-zero error code on error

[ https://issues.apache.org/jira/browse/KAFKA-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe updated KAFKA-14200: - Affects Version/s: 3.3.0 3.3 > kafka-features.sh must exit with non-zero

[GitHub] [kafka] cmccabe opened a new pull request, #12586: KAFKA-14200: kafka-features.sh must exit with non-zero error code on error

cmccabe opened a new pull request, #12586: URL: https://github.com/apache/kafka/pull/12586 kafka-features.sh must exit with a non-zero error code on error. We must do this in order to catch regressions like KAFKA-13990. -- This is an automated message from the Apache Git Service. To re

[jira] [Created] (KAFKA-14200) kafka-features.sh must exit with non-zero error code on error

Colin McCabe created KAFKA-14200: Summary: kafka-features.sh must exit with non-zero error code on error Key: KAFKA-14200 URL: https://issues.apache.org/jira/browse/KAFKA-14200 Project: Kafka

[GitHub] [kafka] ndrwdn commented on pull request #12584: KAFKA-14194: Fix NPE in Cluster.nodeIfOnline

ndrwdn commented on PR #12584: URL: https://github.com/apache/kafka/pull/12584#issuecomment-1235708907 @dajac Thank you for the feedback! I've incorporated the changes you suggested and ran the test case without my change to `Cluster.nodeIfOnline` to verify it still catches the bug. Please

[GitHub] [kafka] ndrwdn commented on a diff in pull request #12584: KAFKA-14194: Fix NPE in Cluster.nodeIfOnline

ndrwdn commented on code in PR #12584: URL: https://github.com/apache/kafka/pull/12584#discussion_r961852281 ## clients/src/test/java/org/apache/kafka/clients/MetadataTest.java: ## @@ -791,6 +791,23 @@ public void testNodeIfOffline() { assertEquals(metadata.fetch().node

[GitHub] [kafka] ndrwdn commented on a diff in pull request #12584: KAFKA-14194: Fix NPE in Cluster.nodeIfOnline

ndrwdn commented on code in PR #12584: URL: https://github.com/apache/kafka/pull/12584#discussion_r961851917 ## clients/src/test/java/org/apache/kafka/clients/MetadataTest.java: ## @@ -791,6 +791,23 @@ public void testNodeIfOffline() { assertEquals(metadata.fetch().node

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

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

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

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

[jira] [Updated] (KAFKA-13725) KIP-768 OAuth code mixes public and internal classes in same package

[ https://issues.apache.org/jira/browse/KAFKA-13725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-13725: --- Fix Version/s: (was: 3.1.2) > KIP-768 OAuth code mixes public and internal classes in sa

[GitHub] [kafka] ramesh-muthusamy commented on pull request #10910: KAFKA-12965 - Graceful clean up of task error metrics

ramesh-muthusamy commented on PR #10910: URL: https://github.com/apache/kafka/pull/10910#issuecomment-1235675819 Hi Chris, Yes thank you -Ramesh On Fri, Sep 2, 2022 at 6:44 AM Chris Egerton ***@***.***> wrote: > @ramesh-muthusamy

[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=17599565#comment-17599565 ] Eslam commented on KAFKA-14130: --- Hello [~guozhang] there is no RackAwarenessIntegrationTes

[GitHub] [kafka] C0urante commented on a diff in pull request #12568: KAFKA-14015: StandaloneHerder::restartConnector should reconfigure tasks if configs have been changed

C0urante commented on code in PR #12568: URL: https://github.com/apache/kafka/pull/12568#discussion_r961796742 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java: ## @@ -294,7 +294,12 @@ public synchronized void restartConnector(St

[GitHub] [kafka] dajac closed pull request #12581: corporate.xml

dajac closed pull request #12581: corporate.xml URL: https://github.com/apache/kafka/pull/12581 -- 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-uns

[GitHub] [kafka] dajac commented on pull request #12581: corporate.xml

dajac commented on PR #12581: URL: https://github.com/apache/kafka/pull/12581#issuecomment-1235603090 Closing this PR as this does not seem right. Feel free to reopen if needed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [kafka] dajac commented on a diff in pull request #12584: KAFKA-14194 Fix NPE in Cluster.nodeIfOnline

dajac commented on code in PR #12584: URL: https://github.com/apache/kafka/pull/12584#discussion_r961769801 ## clients/src/test/java/org/apache/kafka/clients/MetadataTest.java: ## @@ -791,6 +791,23 @@ public void testNodeIfOffline() { assertEquals(metadata.fetch().nodeB

[GitHub] [kafka] C0urante commented on a diff in pull request #12478: KAFKA-13952 fix RetryWithToleranceOperator to respect infinite retries configuration

C0urante commented on code in PR #12478: URL: https://github.com/apache/kafka/pull/12478#discussion_r961727700 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java: ## @@ -268,8 +275,12 @@ void backoff(int attempt, long deadlin

[GitHub] [kafka] yashmayya commented on a diff in pull request #12478: KAFKA-13952 fix RetryWithToleranceOperator to respect infinite retries configuration

yashmayya commented on code in PR #12478: URL: https://github.com/apache/kafka/pull/12478#discussion_r961653921 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java: ## @@ -168,22 +170,26 @@ public synchronized V execute(Opera

[jira] [Assigned] (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 ] Eslam reassigned KAFKA-14130: - Assignee: Eslam > Reduce RackAwarenessIntegrationTest to a unit test >

[GitHub] [kafka] songnon commented on a diff in pull request #12543: KAFKA-10149: Allow auto preferred leader election when there are ongoing partition reassignments

songnon commented on code in PR #12543: URL: https://github.com/apache/kafka/pull/12543#discussion_r961649493 ## core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala: ## @@ -490,6 +490,41 @@ class ControllerIntegrationTest extends QuorumTestHarness {

[GitHub] [kafka] songnon commented on a diff in pull request #12543: KAFKA-10149: Allow auto preferred leader election when there are ongoing partition reassignments

songnon commented on code in PR #12543: URL: https://github.com/apache/kafka/pull/12543#discussion_r961648621 ## core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala: ## @@ -490,6 +490,58 @@ class ControllerIntegrationTest extends QuorumTestHarness {

[jira] [Commented] (KAFKA-14172) bug: State stores lose state when tasks are reassigned under EOS wit…

[ https://issues.apache.org/jira/browse/KAFKA-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599478#comment-17599478 ] John Gray commented on KAFKA-14172: --- [~Horslev] we utilize static membership for our s

[GitHub] [kafka] C0urante commented on a diff in pull request #12478: KAFKA-13952 fix RetryWithToleranceOperator to respect infinite retries configuration

C0urante commented on code in PR #12478: URL: https://github.com/apache/kafka/pull/12478#discussion_r961605579 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java: ## @@ -168,22 +170,26 @@ public synchronized V execute(Operat

[jira] [Updated] (KAFKA-14199) Installed kafka in ubuntu and not able to access in browser. org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104

[ https://issues.apache.org/jira/browse/KAFKA-14199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gops updated KAFKA-14199: - Component/s: streams (was: config) > Installed kafka in ubuntu and not able to access in br

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

vamossagar12 commented on PR #12561: URL: https://github.com/apache/kafka/pull/12561#issuecomment-1235405233 Thanks @C0urante . I had one question on the proposed approach regarding delays. Since the other changes are smallish in nature, I would wait for your response on that one before mak

[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_r961593073 ## 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_r961591300 ## 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_r961591300 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java: ## @@ -307,9 +309,31 @@ ClusterAssignment perform

[GitHub] [kafka] C0urante commented on pull request #10910: KAFKA-12965 - Graceful clean up of task error metrics

C0urante commented on PR #10910: URL: https://github.com/apache/kafka/pull/10910#issuecomment-1235397977 @ramesh-muthusamy can you resolve the merge conflicts? Once that's done, I can do another round and, if everything still looks good, merge this PR. -- This is an automated message from

[jira] [Updated] (KAFKA-14199) Installed kafka in ubuntu and not able to access in browser. org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104

[ https://issues.apache.org/jira/browse/KAFKA-14199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gops updated KAFKA-14199: - Priority: Blocker (was: Critical) > Installed kafka in ubuntu and not able to access in browser. > org.apache

[jira] [Updated] (KAFKA-14199) Installed kafka in ubuntu and not able to access in browser. org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104

[ https://issues.apache.org/jira/browse/KAFKA-14199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gops updated KAFKA-14199: - Priority: Critical (was: Major) > Installed kafka in ubuntu and not able to access in browser. > org.apache.k

[jira] [Updated] (KAFKA-14199) Installed kafka in ubuntu and not able to access in browser. org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104

[ https://issues.apache.org/jira/browse/KAFKA-14199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gops updated KAFKA-14199: - Component/s: config > Installed kafka in ubuntu and not able to access in browser. > org.apache.kafka.common.n

[jira] [Commented] (KAFKA-14184) Kafka streams application crashes due to "UnsupportedOperationException: this should not happen: timestamp() is not supported in standby tasks."

[ https://issues.apache.org/jira/browse/KAFKA-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599428#comment-17599428 ] Suresh Rukmangathan commented on KAFKA-14184: - [~cadonna] - I am afraid I ca

[jira] [Created] (KAFKA-14199) Installed kafka in ubuntu and not able to access in browser. org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104

Gops created KAFKA-14199: Summary: Installed kafka in ubuntu and not able to access in browser. org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104857600) Key: KAFKA-14199

[GitHub] [kafka] showuon commented on pull request #12585: HOTFIX: fix PriorityQueue iteration to assign warmups in priority order

showuon commented on PR #12585: URL: https://github.com/apache/kafka/pull/12585#issuecomment-1235323826 Backported to 3.3. -- 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.

[GitHub] [kafka] showuon merged pull request #12585: HOTFIX: fix PriorityQueue iteration to assign warmups in priority order

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

[GitHub] [kafka] showuon commented on pull request #12585: HOTFIX: fix PriorityQueue iteration to assign warmups in priority order

showuon commented on PR #12585: URL: https://github.com/apache/kafka/pull/12585#issuecomment-1235320263 Failed tests are unrelated: ``` Build / JDK 17 and Scala 2.13 / org.apache.kafka.common.network.SslTransportLayerTest.[1] tlsProtocol=TLSv1.2, useInlinePem=false Build /

[jira] [Updated] (KAFKA-13805) Upgrade vulnerable dependencies march 2022

[ https://issues.apache.org/jira/browse/KAFKA-13805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-13805: -- Fix Version/s: (was: 2.8.2) (was: 3.0.2) > Upgrade vulnerable dependencies

[jira] [Updated] (KAFKA-14198) Release package contains snakeyaml 1.30

[ https://issues.apache.org/jira/browse/KAFKA-14198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-14198: --- Description: snakeyaml 1.30 is vulnerable to CVE-2022-25857: https://security.snyk.io/vuln/

[jira] [Commented] (KAFKA-14198) Release package contains snakeyaml 1.30

[ https://issues.apache.org/jira/browse/KAFKA-14198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599356#comment-17599356 ] Mickael Maison commented on KAFKA-14198: cc [~jagsancio] > Release package cont

[jira] [Created] (KAFKA-14198) Release package contains snakeyaml 1.30

Mickael Maison created KAFKA-14198: -- Summary: Release package contains snakeyaml 1.30 Key: KAFKA-14198 URL: https://issues.apache.org/jira/browse/KAFKA-14198 Project: Kafka Issue Type: Impro

[jira] [Comment Edited] (KAFKA-14197) Kraft broker fails to startup after topic creation failure

[ https://issues.apache.org/jira/browse/KAFKA-14197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599345#comment-17599345 ] Luke Chen edited comment on KAFKA-14197 at 9/2/22 9:06 AM: --- I

[jira] [Commented] (KAFKA-14197) Kraft broker fails to startup after topic creation failure

[ https://issues.apache.org/jira/browse/KAFKA-14197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599345#comment-17599345 ] Luke Chen commented on KAFKA-14197: --- I think we should have a way to notify Replicatio

[jira] [Updated] (KAFKA-14197) Kraft broker fails to startup after topic creation failure

[ https://issues.apache.org/jira/browse/KAFKA-14197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14197: -- Description: In kraft ControllerWriteEvent, we start by trying to apply the record to controller in-m

[jira] [Created] (KAFKA-14197) Kraft broker fails to startup after topic creation failure

Luke Chen created KAFKA-14197: - Summary: Kraft broker fails to startup after topic creation failure Key: KAFKA-14197 URL: https://issues.apache.org/jira/browse/KAFKA-14197 Project: Kafka Issue Ty

[GitHub] [kafka] showuon commented on pull request #12585: HOTFIX: fix PriorityQueue iteration to assign warmups in priority order

showuon commented on PR #12585: URL: https://github.com/apache/kafka/pull/12585#issuecomment-1235184067 > By the way I'm just about to be out for a week so if you want to/wouldn't mind taking over getting this PR merged from here, that would be great! 🙏 No problem. I'll handle it! Enj

[jira] [Commented] (KAFKA-14172) bug: State stores lose state when tasks are reassigned under EOS wit…

[ https://issues.apache.org/jira/browse/KAFKA-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599294#comment-17599294 ] Martin Hørslev commented on KAFKA-14172: [~gray.john] thanks for adding your exp

[GitHub] [kafka] ableegoldman commented on pull request #12585: HOTFIX: fix PriorityQueue iteration to assign warmups in priority order

ableegoldman commented on PR #12585: URL: https://github.com/apache/kafka/pull/12585#issuecomment-1235165665 @showuon yeah this one definitely caught me off guard, I honestly would have doubted it had I not seen the apparent results. 🤷‍♀️ Who knew? By the way I'm just about to be out

[GitHub] [kafka] artemlivshits commented on pull request #12570: KAFKA-14156: Built-in partitioner may create suboptimal batches

artemlivshits commented on PR #12570: URL: https://github.com/apache/kafka/pull/12570#issuecomment-1235146576 @junrao -- looked through all failed tests, don't seem to use this code path and re-ran them locally, all succeeded. -- This is an automated message from the Apache Git Service. T