[jira] [Updated] (KAFKA-16118) Coordinator unloading fails when replica is deleted

2024-01-14 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-16118: Affects Version/s: 3.7.0 > Coordinator unloading fails when replica is deleted >

[jira] [Resolved] (KAFKA-16118) Coordinator unloading fails when replica is deleted

2024-01-14 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16118. - Fix Version/s: 3.8.0 Resolution: Fixed > Coordinator unloading fails when replica is

[jira] [Resolved] (KAFKA-16120) Partition reassignments in ZK migration dual write leaves stray partitions

2024-01-14 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-16120. -- Fix Version/s: 3.7.0 Reviewer: Colin McCabe Assignee: David Mao

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

2024-01-14 Thread Phuc Hong Tran (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806628#comment-17806628 ] Phuc Hong Tran commented on KAFKA-15538: [~lianetm], I have one last question for this ticket,

[jira] [Comment Edited] (KAFKA-15538) Client support for java regex based subscription

2024-01-14 Thread Phuc Hong Tran (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806622#comment-17806622 ] Phuc Hong Tran edited comment on KAFKA-15538 at 1/15/24 5:13 AM: - This

[jira] [Comment Edited] (KAFKA-15538) Client support for java regex based subscription

2024-01-14 Thread Phuc Hong Tran (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806622#comment-17806622 ] Phuc Hong Tran edited comment on KAFKA-15538 at 1/15/24 5:09 AM: - This

[jira] [Resolved] (KAFKA-15538) Client support for java regex based subscription

2024-01-14 Thread Phuc Hong Tran (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phuc Hong Tran resolved KAFKA-15538. Resolution: Fixed > Client support for java regex based subscription >

[jira] [Comment Edited] (KAFKA-15538) Client support for java regex based subscription

2024-01-14 Thread Phuc Hong Tran (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806622#comment-17806622 ] Phuc Hong Tran edited comment on KAFKA-15538 at 1/15/24 5:08 AM: - This

[jira] [Commented] (KAFKA-14507) Add ConsumerGroupPrepareAssignment API

2024-01-14 Thread Zihao Lin (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806623#comment-17806623 ] Zihao Lin commented on KAFKA-14507: --- Hi [~phuctran]  Sorry, feel free to takeover > Add

[jira] [Commented] (KAFKA-15538) Client support for java regex based subscription

2024-01-14 Thread Phuc Hong Tran (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806622#comment-17806622 ] Phuc Hong Tran commented on KAFKA-15538: This is already implemented. I'm closing this ticket.

[jira] [Commented] (KAFKA-16088) Not reading active segments when RemoteFetch return Empty Records.

2024-01-14 Thread Satish Duggana (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806572#comment-17806572 ] Satish Duggana commented on KAFKA-16088: Updated the description clarifying the specific

Re: [PR] KAFKA-15388: Handling remote segment read in case of log compaction [kafka]

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

Re: [PR] KAFKA-15388: Handling remote segment read in case of log compaction [kafka]

2024-01-14 Thread via GitHub
satishd commented on PR #15060: URL: https://github.com/apache/kafka/pull/15060#issuecomment-1891112974 Merging it to trunk as the test failures are unrelated to this change. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (KAFKA-16120) Partition reassignments in ZK migration dual write leaves stray partitions

2024-01-14 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806565#comment-17806565 ] Colin McCabe commented on KAFKA-16120: -- KAFKA-14616 is a separate bug, unfortunately. I am working

Re: [PR] KAFKA-16126: Kcontroller dynamic configurations may fail to apply at startup [kafka]

2024-01-14 Thread via GitHub
cmccabe commented on PR #15192: URL: https://github.com/apache/kafka/pull/15192#issuecomment-1891091446 I included a test. It sometimes passes even when the fix is not present, because of the nature of the bug. Adding a `Thread.sleep` makes it consistently fail in the buggy version. --

[PR] KAFKA-16126: Kcontroller dynamic configurations may fail to apply at startup [kafka]

2024-01-14 Thread via GitHub
cmccabe opened a new pull request, #15192: URL: https://github.com/apache/kafka/pull/15192 Some kcontroller dynamic configurations may fail to apply at startup. This happens because there is a race between registering the reconfigurables to the DynamicBrokerConfig class, and receiving the

[jira] [Created] (KAFKA-16129) Add integration test for KIP-977

2024-01-14 Thread Qichao Chu (Jira)
Qichao Chu created KAFKA-16129: -- Summary: Add integration test for KIP-977 Key: KAFKA-16129 URL: https://issues.apache.org/jira/browse/KAFKA-16129 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-16127) Reset corresponding verbosity configs when topic is deleted

2024-01-14 Thread Qichao Chu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qichao Chu updated KAFKA-16127: --- Priority: Minor (was: Critical) > Reset corresponding verbosity configs when topic is deleted >

[jira] [Created] (KAFKA-16128) Use metrics.verbosity in throughput metrics

2024-01-14 Thread Qichao Chu (Jira)
Qichao Chu created KAFKA-16128: -- Summary: Use metrics.verbosity in throughput metrics Key: KAFKA-16128 URL: https://issues.apache.org/jira/browse/KAFKA-16128 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-16127) Reset corresponding verbosity configs when topic is deleted

2024-01-14 Thread Qichao Chu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qichao Chu updated KAFKA-16127: --- Priority: Critical (was: Major) > Reset corresponding verbosity configs when topic is deleted >

[jira] [Created] (KAFKA-16127) Reset corresponding verbosity configs when topic is deleted

2024-01-14 Thread Qichao Chu (Jira)
Qichao Chu created KAFKA-16127: -- Summary: Reset corresponding verbosity configs when topic is deleted Key: KAFKA-16127 URL: https://issues.apache.org/jira/browse/KAFKA-16127 Project: Kafka

[jira] [Created] (KAFKA-16126) Kcontroller dynamic configurations may fail to apply at startup

2024-01-14 Thread Colin McCabe (Jira)
Colin McCabe created KAFKA-16126: Summary: Kcontroller dynamic configurations may fail to apply at startup Key: KAFKA-16126 URL: https://issues.apache.org/jira/browse/KAFKA-16126 Project: Kafka

[jira] [Created] (KAFKA-16125) Add parser for the metrics.verbosity config

2024-01-14 Thread Qichao Chu (Jira)
Qichao Chu created KAFKA-16125: -- Summary: Add parser for the metrics.verbosity config Key: KAFKA-16125 URL: https://issues.apache.org/jira/browse/KAFKA-16125 Project: Kafka Issue Type: Task

Re: [PR] KAFKA-15743: KRaft support in ReplicationQuotasTest [kafka]

2024-01-14 Thread via GitHub
wernerdv commented on PR #15191: URL: https://github.com/apache/kafka/pull/15191#issuecomment-1891071688 Hello, @jolshan @mimaison Please, take a look. Tests passed. https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-15191/2/testReport/kafka.server/ReplicationQuotasTest/ --

[jira] [Created] (KAFKA-16124) Create metrics.verbosity dynamic config for controlling metrics verbosity

2024-01-14 Thread Qichao Chu (Jira)
Qichao Chu created KAFKA-16124: -- Summary: Create metrics.verbosity dynamic config for controlling metrics verbosity Key: KAFKA-16124 URL: https://issues.apache.org/jira/browse/KAFKA-16124 Project: Kafka

Re: [PR] KAFKA-14683 Migrate #testStartPaused to Mockito [kafka]

2024-01-14 Thread via GitHub
hgeraldino commented on PR #14663: URL: https://github.com/apache/kafka/pull/14663#issuecomment-1891034358 > > Hi @hgeraldino Thanks for taking on the migration! > > I understand the idea behind your refactor-then-deduplicate strategy, but I think the excessive duplication is making it

[PR] KAFKA-15743: KRaft support in ReplicationQuotasTest [kafka]

2024-01-14 Thread via GitHub
wernerdv opened a new pull request, #15191: URL: https://github.com/apache/kafka/pull/15191 Updated to support KRaft mode. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ]

Re: [PR] KAFKA-5863: Avoid NPE when RestClient calls expecting no-content receive content. [kafka]

2024-01-14 Thread via GitHub
yashmayya commented on code in PR #13294: URL: https://github.com/apache/kafka/pull/13294#discussion_r1451742635 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java: ## @@ -67,13 +68,13 @@ HttpClient httpClient(SslContextFactory

Re: [PR] improve TopicCommandIntegrationTest to be less flaky [kafka]

2024-01-14 Thread via GitHub
Owen-CH-Leung commented on PR #14891: URL: https://github.com/apache/kafka/pull/14891#issuecomment-1890892504 > > Thanks for your feedback! Do you mean we should keep the existing API calls like createAndWaitTopic(buildTopicCommandOptionsWithBootstrap( "--create", "--partitions", "2",

Re: [PR] improve TopicCommandIntegrationTest to be less flaky [kafka]

2024-01-14 Thread via GitHub
Owen-CH-Leung commented on code in PR #14891: URL: https://github.com/apache/kafka/pull/14891#discussion_r1451689247 ## tools/src/test/java/org/apache/kafka/tools/TopicCommandIntegrationTest.java: ## @@ -787,16 +827,28 @@ public void

Re: [PR] improve TopicCommandIntegrationTest to be less flaky [kafka]

2024-01-14 Thread via GitHub
Owen-CH-Leung commented on code in PR #14891: URL: https://github.com/apache/kafka/pull/14891#discussion_r1451689158 ## tools/src/test/java/org/apache/kafka/tools/TopicCommandIntegrationTest.java: ## @@ -472,10 +516,11 @@ public void testCreateAlterTopicWithRackAware(String

Re: [PR] improve TopicCommandIntegrationTest to be less flaky [kafka]

2024-01-14 Thread via GitHub
Owen-CH-Leung commented on code in PR #14891: URL: https://github.com/apache/kafka/pull/14891#discussion_r1451688709 ## tools/src/test/java/org/apache/kafka/tools/TopicCommandIntegrationTest.java: ## @@ -159,100 +166,117 @@ public void close() throws Exception {