[jira] [Commented] (KAFKA-16027) Refactor MetadataTest#testUpdatePartitionLeadership

2024-09-01 Thread TengYao Chi (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878480#comment-17878480 ] TengYao Chi commented on KAFKA-16027: - Hi all Since this issue is pending for a lon

Re: [PR] [WIP] KAFKA-16553: Add config logging for controller [kafka]

2024-09-01 Thread via GitHub
github-actions[bot] commented on PR #15826: URL: https://github.com/apache/kafka/pull/15826#issuecomment-2323747312 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

Re: [PR] KAFKA-16027: MINOR Refactor MetadataTest#testUpdatePartitionLeadership (2) [kafka]

2024-09-01 Thread via GitHub
github-actions[bot] commented on PR #15857: URL: https://github.com/apache/kafka/pull/15857#issuecomment-2323747287 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

Re: [PR] KIP-966 unclean recovery elect leader request [kafka]

2024-09-01 Thread via GitHub
github-actions[bot] commented on PR #15876: URL: https://github.com/apache/kafka/pull/15876#issuecomment-2323747266 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

[jira] [Commented] (KAFKA-17405) how to enforce the MV 3.5 when enabling tiered storage? maybe: enforce it once at the feature version level

2024-09-01 Thread PoAn Yang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878461#comment-17878461 ] PoAn Yang commented on KAFKA-17405: --- Hi [~chia7712], I'm interested in this. If you're

[jira] [Assigned] (KAFKA-17405) how to enforce the MV 3.5 when enabling tiered storage? maybe: enforce it once at the feature version level

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-17405: -- Assignee: PoAn Yang (was: Chia-Ping Tsai) > how to enforce the MV 3.5 when enabling

[jira] [Comment Edited] (KAFKA-17405) how to enforce the MV 3.5 when enabling tiered storage? maybe: enforce it once at the feature version level

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877932#comment-17877932 ] Chia-Ping Tsai edited comment on KAFKA-17405 at 9/2/24 3:12 AM: --

Re: [PR] KAFKA-14772: Add ConsumerGroupHeartbeat and ConsumerGroupDescribe API to AuthorizerIntegrationTest [kafka]

2024-09-01 Thread via GitHub
DL1231 commented on PR #17044: URL: https://github.com/apache/kafka/pull/17044#issuecomment-2323619774 @dajac PTAL when you get a chance. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the spec

Re: [PR] KAFKA-17442: Handled persister errors with write async calls (KIP-932) [kafka]

2024-09-01 Thread via GitHub
junrao merged PR #16956: URL: https://github.com/apache/kafka/pull/16956 -- 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

Re: [PR] KAFKA-17442: Handled persister errors with write async calls (KIP-932) [kafka]

2024-09-01 Thread via GitHub
apoorvmittal10 commented on PR #16956: URL: https://github.com/apache/kafka/pull/16956#issuecomment-2323492920 > @apoorvmittal10 : Thanks for the PR. The code LGTM. Are the test failure related? If not, have they all been tracked? Unrelated tests failure, I have triaged the failures.

[jira] [Created] (KAFKA-17464) Flaky test: org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest.testWakeupAfterSyncGroupSentExternalCompletion

2024-09-01 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17464: - Summary: Flaky test: org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest.testWakeupAfterSyncGroupSentExternalCompletion Key: KAFKA-17464 URL: https://issues.apac

[jira] [Reopened] (KAFKA-15896) Flaky test: shouldQuerySpecificStalePartitionStores() – org.apache.kafka.streams.integration.StoreQueryIntegrationTest

2024-09-01 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reopened KAFKA-15896: --- Failed again: https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-16956/5/testReport/org

[jira] [Created] (KAFKA-17463) Flaky test: kafka.api.PlaintextAdminIntegrationTest."testShareGroups(String).quorum=kraft+kip932"

2024-09-01 Thread Apoorv Mittal (Jira)
Apoorv Mittal created KAFKA-17463: - Summary: Flaky test: kafka.api.PlaintextAdminIntegrationTest."testShareGroups(String).quorum=kraft+kip932" Key: KAFKA-17463 URL: https://issues.apache.org/jira/browse/KAFKA-1746

[jira] [Updated] (KAFKA-17462) Removes intermediateTopicsOption from StreamsResetter

2024-09-01 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17462: Description: Since the removal of the #through method in Jira: https://issues.apache.org/

Re: [PR] KAFKA-15793 Fix ZkMigrationIntegrationTest#testMigrateTopicDeletions [kafka]

2024-09-01 Thread via GitHub
soarez commented on code in PR #17004: URL: https://github.com/apache/kafka/pull/17004#discussion_r1740188303 ## core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala: ## @@ -391,21 +405,25 @@ class ZkMigrationIntegrationTest { TestUtils.waitUntilTrue(

Re: [PR] KAFKA-12823 Remove Deprecated method KStream#through [kafka]

2024-09-01 Thread via GitHub
ardada2468 commented on code in PR #16761: URL: https://github.com/apache/kafka/pull/16761#discussion_r1740188371 ## tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java: ## @@ -584,8 +584,8 @@ public StreamsResetterOptions(String[] args) { .ofType(St

Re: [PR] KAFKA-12823 Remove Deprecated method KStream#through [kafka]

2024-09-01 Thread via GitHub
mjsax commented on code in PR #16761: URL: https://github.com/apache/kafka/pull/16761#discussion_r1740186297 ## tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java: ## @@ -584,8 +584,8 @@ public StreamsResetterOptions(String[] args) { .ofType(String.

Re: [PR] KAFKA-12823 Remove Deprecated method KStream#through [kafka]

2024-09-01 Thread via GitHub
ardada2468 commented on code in PR #16761: URL: https://github.com/apache/kafka/pull/16761#discussion_r1740185329 ## tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java: ## @@ -584,8 +584,8 @@ public StreamsResetterOptions(String[] args) { .ofType(St

[jira] [Created] (KAFKA-17462) Removes intermediateTopicsOption from StreamsResetter

2024-09-01 Thread Arnav Dadarya (Jira)
Arnav Dadarya created KAFKA-17462: - Summary: Removes intermediateTopicsOption from StreamsResetter Key: KAFKA-17462 URL: https://issues.apache.org/jira/browse/KAFKA-17462 Project: Kafka Issue

[jira] [Updated] (KAFKA-16337) Remove Deprecates APIs of Kafka Streams in 5.0

2024-09-01 Thread Arnav Dadarya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnav Dadarya updated KAFKA-16337: -- Priority: Major (was: Blocker) > Remove Deprecates APIs of Kafka Streams in 5.0 > ---

[jira] [Updated] (KAFKA-16337) Remove Deprecates APIs of Kafka Streams in 5.0

2024-09-01 Thread Arnav Dadarya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnav Dadarya updated KAFKA-16337: -- Priority: Blocker (was: Major) > Remove Deprecates APIs of Kafka Streams in 5.0 > ---

Re: [PR] KAFKA-12823 Remove Deprecated method KStream#through [kafka]

2024-09-01 Thread via GitHub
ardada2468 commented on code in PR #16761: URL: https://github.com/apache/kafka/pull/16761#discussion_r1740177893 ## tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java: ## @@ -584,8 +584,8 @@ public StreamsResetterOptions(String[] args) { .ofType(St

Re: [PR] KAFKA-12823 Remove Deprecated method KStream#through [kafka]

2024-09-01 Thread via GitHub
mjsax commented on code in PR #16761: URL: https://github.com/apache/kafka/pull/16761#discussion_r1740177854 ## tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java: ## @@ -584,8 +584,8 @@ public StreamsResetterOptions(String[] args) { .ofType(String.

Re: [PR] KAFKA-12823 Remove Deprecated method KStream#through [kafka]

2024-09-01 Thread via GitHub
mjsax commented on code in PR #16761: URL: https://github.com/apache/kafka/pull/16761#discussion_r1740177149 ## tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java: ## @@ -584,8 +584,8 @@ public StreamsResetterOptions(String[] args) { .ofType(String.

Re: [PR] KAFKA-12823 Remove Deprecated method KStream#through [kafka]

2024-09-01 Thread via GitHub
ardada2468 commented on code in PR #16761: URL: https://github.com/apache/kafka/pull/16761#discussion_r1740173274 ## tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java: ## @@ -584,8 +584,8 @@ public StreamsResetterOptions(String[] args) { .ofType(St

Re: [PR] KAFKA-17414: Move RequestLocal to server-common module [kafka]

2024-09-01 Thread via GitHub
wernerdv commented on code in PR #16986: URL: https://github.com/apache/kafka/pull/16986#discussion_r1740171023 ## server-common/src/main/java/org/apache/kafka/server/common/RequestLocal.java: ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[jira] [Updated] (KAFKA-17400) Introduce a purgatory to deal with share fetch requests that cannot be completed instantaneously

2024-09-01 Thread Andrew Schofield (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield updated KAFKA-17400: - Summary: Introduce a purgatory to deal with share fetch requests that cannot be complete

Re: [PR] KAFKA-16379: Coordinator event queue, processing, flush, purgatory time histograms [kafka]

2024-09-01 Thread via GitHub
junrao commented on code in PR #16949: URL: https://github.com/apache/kafka/pull/16949#discussion_r1740159483 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/HdrHistogram.java: ## @@ -0,0 +1,145 @@ +/* + * Licensed to the Apache Software Foundation

Re: [PR] KAFKA-17338 ConsumerConfig should prevent using partition assignors with CONSUMER group protocol [kafka]

2024-09-01 Thread via GitHub
chia7712 commented on code in PR #16899: URL: https://github.com/apache/kafka/pull/16899#discussion_r1740156232 ## clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java: ## @@ -384,7 +385,9 @@ public class ConsumerConfig extends AbstractConfig { privat

Re: [PR] KAFKA-17414: Move RequestLocal to server-common module [kafka]

2024-09-01 Thread via GitHub
chia7712 commented on code in PR #16986: URL: https://github.com/apache/kafka/pull/16986#discussion_r1740153222 ## server-common/src/main/java/org/apache/kafka/server/common/RequestLocal.java: ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

Re: [PR] KAFKA-17285: Consider using `Utils.closeQuietly` to replace `CoreUtils.swallow` when handling Closeable objects [kafka]

2024-09-01 Thread via GitHub
chia7712 commented on PR #16843: URL: https://github.com/apache/kafka/pull/16843#issuecomment-2323403342 @bboyleonp666 any updates? -- 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 co

Re: [PR] KAFKA-15853: Move TransactionLogConfig and TransactionStateManagerConfig getters out of KafkaConfig [kafka]

2024-09-01 Thread via GitHub
chia7712 commented on PR #16665: URL: https://github.com/apache/kafka/pull/16665#issuecomment-2323403211 @OmniaGM Sorry that could you please fix the conflicts again? This PR will have highest priority in my queue -- This is an automated message from the Apache Git Service. To respond to

Re: [PR] KAFKA-17320: Move SensorAccess to server-common module [kafka]

2024-09-01 Thread via GitHub
chia7712 merged PR #16864: URL: https://github.com/apache/kafka/pull/16864 -- 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

Re: [PR] KAFKA-17461 move the .github/readme to ./github/workflows/readme [kafka]

2024-09-01 Thread via GitHub
mumrah commented on PR #17069: URL: https://github.com/apache/kafka/pull/17069#issuecomment-2323396562 Thanks @brandboat and @chia7712 for fixing this! I had no idea this was override our readme 😅 -- This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Resolved] (KAFKA-17461) move the .github/readme to ./github/workflows/readme

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17461. Fix Version/s: 4.0.0 Resolution: Fixed > move the .github/readme to ./github/workfl

Re: [PR] KAFKA-17461 move the .github/readme to ./github/workflows/readme [kafka]

2024-09-01 Thread via GitHub
chia7712 merged PR #17069: URL: https://github.com/apache/kafka/pull/17069 -- 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

Re: [PR] KAFKA-17461 move the .github/readme to ./github/workflows/readme [kafka]

2024-09-01 Thread via GitHub
chia7712 commented on PR #17069: URL: https://github.com/apache/kafka/pull/17069#issuecomment-2323392410 I will merge it directly, as main page (see https://github.com/brandboat/kafka/tree/KAFKA-17461) is corrected now. -- This is an automated message from the Apache Git Service. To respo

[PR] KAFKA-17461 move the .github/readme to ./github/workflows/readme [kafka]

2024-09-01 Thread via GitHub
brandboat opened a new pull request, #17069: URL: https://github.com/apache/kafka/pull/17069 related to https://issues.apache.org/jira/browse/KAFKA-17461 According to [GitHub readme rules](https://docs.github.com/en/repositories/managing-your-repositorys-settings-and-features/customiz

[jira] [Commented] (KAFKA-17461) move the .github/readme to ./github/workflows/readme

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878437#comment-17878437 ] Chia-Ping Tsai commented on KAFKA-17461: cc [~davidarthur] > move the .github

[jira] [Updated] (KAFKA-17461) move the .github/readme to ./github/workflows/readme

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17461: --- Description: According to GitHub readme rules ( https://docs.github.com/en/repositories/mana

[jira] [Commented] (KAFKA-17461) move the .github/readme to ./github/workflows/readme

2024-09-01 Thread Kuan Po Tseng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878436#comment-17878436 ] Kuan Po Tseng commented on KAFKA-17461: --- Hi [~chia7712] , I can help fix this Jira

[jira] [Assigned] (KAFKA-17461) move the .github/readme to ./github/workflows/readme

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-17461: -- Assignee: Kuan Po Tseng (was: Chia-Ping Tsai) > move the .github/readme to ./github/

[jira] [Updated] (KAFKA-17461) move the .github/readme to ./github/workflows/readme

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17461: --- Summary: move the .github/readme to ./github/workflows/readme (was: move the .github/readme

[jira] [Created] (KAFKA-17461) move the .github/readme to ./github/workaround/readme

2024-09-01 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-17461: -- Summary: move the .github/readme to ./github/workaround/readme Key: KAFKA-17461 URL: https://issues.apache.org/jira/browse/KAFKA-17461 Project: Kafka Iss

[jira] [Updated] (KAFKA-17213) Change exceptions like ControllerMovedException to be retriable

2024-09-01 Thread xiaochen.zhou (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaochen.zhou updated KAFKA-17213: -- Summary: Change exceptions like ControllerMovedException to be retriable (was: Change Control

[PR] Change ControllerMovedException from ApiException to InvalidMetadataException [kafka]

2024-09-01 Thread via GitHub
xiaochen-zhou opened a new pull request, #17068: URL: https://github.com/apache/kafka/pull/17068 jira: https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-17213 ## More detailed description of your change After the Kafka client fails to send, it will update the metad

Re: [PR] KAFKA-17213: Change ControllerMovedException from ApiException to InvalidMetadataException [kafka]

2024-09-01 Thread via GitHub
xiaochen-zhou closed pull request #16713: KAFKA-17213: Change ControllerMovedException from ApiException to InvalidMetadataException URL: https://github.com/apache/kafka/pull/16713 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (KAFKA-17233) MirrorCheckpointConnector should use batched listConsumerGroupOffsets

2024-09-01 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-17233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878434#comment-17878434 ] João Pedro Fonseca commented on KAFKA-17233: Another example:   I run grad

[jira] (KAFKA-17296) Add a new compression option on the broker side

2024-09-01 Thread xiaochen.zhou (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17296 ] xiaochen.zhou deleted comment on KAFKA-17296: --- was (Author: JIRAUSER306248): Thanks for your reply, I'll be happy to create a kip > Add a new compression option on the broker side > --

[jira] [Commented] (KAFKA-17296) Add a new compression option on the broker side

2024-09-01 Thread xiaochen.zhou (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878433#comment-17878433 ] xiaochen.zhou commented on KAFKA-17296: --- Thanks for your reply, I'll be happy to c

[jira] [Commented] (KAFKA-17296) Add a new compression option on the broker side

2024-09-01 Thread xiaochen.zhou (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878432#comment-17878432 ] xiaochen.zhou commented on KAFKA-17296: --- Thanks for your reply, I'll be happy to c

[jira] [Resolved] (KAFKA-17293) New consumer HeartbeatRequestManager should rediscover disconnected coordinator

2024-09-01 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans resolved KAFKA-17293. Reviewer: Lianet Magrans Resolution: Fixed > New consumer HeartbeatRequestManager sh

Re: [PR] KAFKA-17293: New consumer HeartbeatRequestManager should rediscover disconnected coordinator [kafka]

2024-09-01 Thread via GitHub
lianetm merged PR #16844: URL: https://github.com/apache/kafka/pull/16844 -- 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.

[jira] [Resolved] (KAFKA-16192) Introduce usage of flexible records to coordinators

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16192. Fix Version/s: 3.9.0 Resolution: Fixed > Introduce usage of flexible records to coo

[jira] [Updated] (KAFKA-17210) Broker fixes for smooth concurrent fetches on share partition

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17210: --- Fix Version/s: 3.9.0 (was: 4.0.0) > Broker fixes for smooth concurren

[jira] [Updated] (KAFKA-17192) MirrorMaker2 worker config does not pass config.providers value to connectors

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17192: --- Fix Version/s: (was: 4.0.0) > MirrorMaker2 worker config does not pass config.providers

[jira] [Updated] (KAFKA-17232) MirrorCheckpointConnector does not generate task configs if initial consumer group load times out

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17232: --- Fix Version/s: (was: 4.0.0) > MirrorCheckpointConnector does not generate task configs i

[jira] [Updated] (KAFKA-17242) MirrorCheckpointTask prints spurious timeout for starting checkpoint and offset sync stores

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17242: --- Fix Version/s: (was: 4.0.0) > MirrorCheckpointTask prints spurious timeout for starting

[jira] [Updated] (KAFKA-17223) Retrying the call after encoutering UnsupportedVersionException will cause ConcurrentModificationException

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17223: --- Fix Version/s: (was: 4.0.0) > Retrying the call after encoutering UnsupportedVersionExce

[jira] [Resolved] (KAFKA-17190) AssignmentsManager gets stuck retrying on deleted topics

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17190. Fix Version/s: 3.9.0 Resolution: Fixed > AssignmentsManager gets stuck retrying on

[jira] [Updated] (KAFKA-17238) Move VoterSet and ReplicaKey from raft.internals to raft

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17238: --- Fix Version/s: (was: 4.0.0) > Move VoterSet and ReplicaKey from raft.internals to raft >

[jira] [Updated] (KAFKA-16887) document remote copy/fetch quotas metrics

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-16887: --- Fix Version/s: 3.9.0 > document remote copy/fetch quotas metrics > -

Re: [PR] MINOR: Add integration test for ReassignPartitionsCommand#curReassignmentsToString [kafka]

2024-09-01 Thread via GitHub
m1a2st closed pull request #17043: MINOR: Add integration test for ReassignPartitionsCommand#curReassignmentsToString URL: https://github.com/apache/kafka/pull/17043 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (KAFKA-17360) local log retention ms/bytes "-2" is not treated correctly

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17360: --- Fix Version/s: (was: 4.0.0) > local log retention ms/bytes "-2" is not treated correctly

[jira] [Updated] (KAFKA-17335) Lack of default for URL encoding configuration for OAuth causes NPE

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17335: --- Fix Version/s: (was: 4.0.0) > Lack of default for URL encoding configuration for OAuth c

[jira] [Updated] (KAFKA-15746) KRaft support in ControllerMutationQuotaTest

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-15746: --- Fix Version/s: 3.9.0 (was: 4.0.0) > KRaft support in ControllerMutati

[jira] [Updated] (KAFKA-17310) locking the offline dir can destroy the broker exceptionally

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17310: --- Fix Version/s: (was: 4.0.0) > locking the offline dir can destroy the broker exceptional

[jira] [Updated] (KAFKA-17315) Fix the behavior of delegation tokens that expire immediately upon creation in KRaft mode

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17315: --- Fix Version/s: (was: 4.0.0) > Fix the behavior of delegation tokens that expire immediat

[jira] [Assigned] (KAFKA-17460) Revisit downgrade_test.py

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-17460: -- Assignee: Chia-Chuan Yu (was: Chia-Ping Tsai) > Revisit downgrade_test.py >

[jira] [Updated] (KAFKA-17460) Revisit downgrade_test.py

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17460: --- Fix Version/s: 4.0.0 > Revisit downgrade_test.py > - > >

[jira] [Resolved] (KAFKA-17331) Throw/return unsupported version exception if the server/client does NOT support EarliestLocalSpec and LatestTieredSpec

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17331. Resolution: Fixed trunk: [https://github.com/apache/kafka/commit/0fde28049aab195c19796c28

[jira] [Updated] (KAFKA-17331) Throw/return unsupported version exception if the server/client does NOT support EarliestLocalSpec and LatestTieredSpec

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17331: --- Fix Version/s: (was: 4.0.0) > Throw/return unsupported version exception if the server/c

[jira] [Updated] (KAFKA-17331) Throw/return unsupported version exception if the server/client does NOT support EarliestLocalSpec and LatestTieredSpec

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17331: --- Fix Version/s: 4.0.0 > Throw/return unsupported version exception if the server/client does

Re: [PR] KAFKA-17331: Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec [kafka]

2024-09-01 Thread via GitHub
chia7712 merged PR #16873: URL: https://github.com/apache/kafka/pull/16873 -- 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

Re: [PR] KAFKA-17331: Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec [kafka]

2024-09-01 Thread via GitHub
chia7712 commented on PR #16873: URL: https://github.com/apache/kafka/pull/16873#issuecomment-2323335824 I run all core e2e, and the flaky/failure are shown below. 1. `reassign_partitions_test.py` is flaky https://issues.apache.org/jira/browse/KAFKA-17459 2. `transactions_mixed_v

[jira] [Commented] (KAFKA-17460) Revisit downgrade_test.py

2024-09-01 Thread Chia-Chuan Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878427#comment-17878427 ] Chia-Chuan Yu commented on KAFKA-17460: --- Hi, [~chia7712]  Can I take this one? th

[jira] [Created] (KAFKA-17460) Revisit downgrade_test.py

2024-09-01 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-17460: -- Summary: Revisit downgrade_test.py Key: KAFKA-17460 URL: https://issues.apache.org/jira/browse/KAFKA-17460 Project: Kafka Issue Type: Test Re

Re: [PR] KAFKA-17374: add bootstrap.controller to kafka-reassign-partitions.sh [kafka]

2024-09-01 Thread via GitHub
m1a2st commented on code in PR #16964: URL: https://github.com/apache/kafka/pull/16964#discussion_r1740091030 ## tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommandArgsTest.java: ## @@ -29,7 +29,7 @@ @Timeout(60) public class ReassignPartitionsComma

[jira] [Created] (KAFKA-17459) Stabalize reassign_partitions_test.py

2024-09-01 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-17459: -- Summary: Stabalize reassign_partitions_test.py Key: KAFKA-17459 URL: https://issues.apache.org/jira/browse/KAFKA-17459 Project: Kafka Issue Type: Test

Re: [PR] KAFKA-15561: Client support for new SubscriptionPattern based subscription [kafka]

2024-09-01 Thread via GitHub
AndrewJSchofield commented on code in PR #15188: URL: https://github.com/apache/kafka/pull/15188#discussion_r1740038808 ## clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java: ## @@ -141,6 +141,16 @@ public synchronized void subscribe(Pattern pattern) {

[jira] [Commented] (KAFKA-17458) Add 3.8 to transactions_upgrade_test.py, transactions_mixed_versions_test.py, and kraft_upgrade_test.py

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878415#comment-17878415 ] Chia-Ping Tsai commented on KAFKA-17458: [~bboyleonp]  sure, thanks for taking o

[jira] [Assigned] (KAFKA-17458) Add 3.8 to transactions_upgrade_test.py, transactions_mixed_versions_test.py, and kraft_upgrade_test.py

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-17458: -- Assignee: bboyleonp (was: Chia-Ping Tsai) > Add 3.8 to transactions_upgrade_test.py,

Re: [PR] MINOR: remove get prefix for internal DSL methods [kafka]

2024-09-01 Thread via GitHub
chia7712 merged PR #17050: URL: https://github.com/apache/kafka/pull/17050 -- 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

[jira] [Commented] (KAFKA-17458) Add 3.8 to transactions_upgrade_test.py, transactions_mixed_versions_test.py, and kraft_upgrade_test.py

2024-09-01 Thread bboyleonp (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878414#comment-17878414 ] bboyleonp commented on KAFKA-17458: --- Hi [~chia7712] , may I take this one? > Add 3.8

[jira] [Commented] (KAFKA-17458) Add 3.8 to transactions_upgrade_test.py, transactions_mixed_versions_test.py, and kraft_upgrade_test.py

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878413#comment-17878413 ] Chia-Ping Tsai commented on KAFKA-17458: [~cmccabe] This is not related to bugs,

[jira] [Updated] (KAFKA-17458) Add 3.8 to transactions_upgrade_test.py, transactions_mixed_versions_test.py, and kraft_upgrade_test.py

2024-09-01 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17458: --- Fix Version/s: 4.0.0 3.9.0 > Add 3.8 to transactions_upgrade_test.py, tra

[jira] [Created] (KAFKA-17458) Add 3.8 to transactions_upgrade_test.py, transactions_mixed_versions_test.py, and kraft_upgrade_test.py

2024-09-01 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-17458: -- Summary: Add 3.8 to transactions_upgrade_test.py, transactions_mixed_versions_test.py, and kraft_upgrade_test.py Key: KAFKA-17458 URL: https://issues.apache.org/jira/browse/KA

[jira] [Commented] (KAFKA-17101) Mirror maker internal topics cleanup policy changes to 'delete' from 'compact'

2024-09-01 Thread Anh Tuan Nguyen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878411#comment-17878411 ] Anh Tuan Nguyen commented on KAFKA-17101: - I'm facing same issue with mirror mak

Re: [PR] KAFKA-17454: Fix failed transactions_mixed_versions_test.py when running with 3.2 [kafka]

2024-09-01 Thread via GitHub
frankvicky commented on code in PR #17067: URL: https://github.com/apache/kafka/pull/17067#discussion_r1739996237 ## tests/kafkatest/tests/core/transactions_mixed_versions_test.py: ## @@ -199,6 +199,7 @@ def test_transactions_mixed_versions(self, old_kafka_version, metadata_quo

Re: [PR] KAFKA-16792: Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) [kafka]

2024-09-01 Thread via GitHub
TaiJuWu commented on code in PR #16982: URL: https://github.com/apache/kafka/pull/16982#discussion_r1739840322 ## clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java: ## @@ -2507,32 +2521,35 @@ public void testCurrentLag(GroupProtocol groupProtocol) {

Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]

2024-09-01 Thread via GitHub
smjn commented on code in PR #17011: URL: https://github.com/apache/kafka/pull/17011#discussion_r1739991289 ## core/src/test/scala/unit/kafka/server/AutoTopicCreationManagerTest.scala: ## @@ -38,7 +38,8 @@ import org.apache.kafka.common.security.auth.{KafkaPrincipal, KafkaPrinc