Re: [PR] KAFKA-16481: Fixing flaky test kafka.server.ReplicaManagerTest#testRemoteLogReaderMetrics [kafka]

2024-04-07 Thread via GitHub
vamossagar12 commented on PR #15677: URL: https://github.com/apache/kafka/pull/15677#issuecomment-2041849012 Thanks for the review @showuon and thanks for the input. I agree to your proposal, we can first merge this and then I will look at the adding more resilience on the test for this

Re: [PR] KAFKA-15746: KRaft support in ControllerMutationQuotaTest [kafka]

2024-04-07 Thread via GitHub
github-actions[bot] commented on PR #15038: URL: https://github.com/apache/kafka/pull/15038#issuecomment-2041800868 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

Re: [PR] MINOR: Add retry mechanism to EOS example [kafka]

2024-04-07 Thread via GitHub
gaoran10 commented on PR #15561: URL: https://github.com/apache/kafka/pull/15561#issuecomment-2041793310 Sorry for the late response, great work! -- 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

[PR] KAFKA-16481: Fixing flaky test kafka.server.ReplicaManagerTest#testRemoteLogReaderMetrics [kafka]

2024-04-07 Thread via GitHub
vamossagar12 opened a new pull request, #15677: URL: https://github.com/apache/kafka/pull/15677 Noticed in the build: https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15621/32/tests/ There are a lot of NPEs of the form: ``` [2024-04-05

[PR] KAFKA-16482: Eliminate the IDE warnings of accepting ClusterConfig in BeforeEach [kafka]

2024-04-07 Thread via GitHub
KevinZTW opened a new pull request, #15676: URL: https://github.com/apache/kafka/pull/15676 *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

[jira] [Assigned] (KAFKA-16049) Can you please share tutorial how to run Latest Kafka (3.6.0) with SASL_SSL

2024-04-07 Thread Kelvin Lui (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kelvin Lui reassigned KAFKA-16049: -- Assignee: (was: Kelvin Lui) > Can you please share tutorial how to run Latest Kafka

[jira] [Assigned] (KAFKA-16049) Can you please share tutorial how to run Latest Kafka (3.6.0) with SASL_SSL

2024-04-07 Thread Kelvin Lui (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kelvin Lui reassigned KAFKA-16049: -- Assignee: Kelvin Lui > Can you please share tutorial how to run Latest Kafka (3.6.0) with

Re: [PR] MINOR: Fix usage of none in javadoc [kafka]

2024-04-07 Thread via GitHub
chia7712 merged PR #15674: URL: https://github.com/apache/kafka/pull/15674 -- 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] [Updated] (KAFKA-16482) Eliminate the IDE warnings of accepting ClusterConfig in BeforeEach

2024-04-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-16482: --- Summary: Eliminate the IDE warnings of accepting ClusterConfig in BeforeEach (was: Avoid

[jira] [Commented] (KAFKA-16482) Avoid changing ClusterConfig in `BeforeEach` phase

2024-04-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834745#comment-17834745 ] Chia-Ping Tsai commented on KAFKA-16482: BTW, we can eliminate the IDE error by updating configs

Re: [PR] KAFKA-16310 ListOffsets doesn't report the offset with maxTimestamp a… [kafka]

2024-04-07 Thread via GitHub
chia7712 commented on PR #15621: URL: https://github.com/apache/kafka/pull/15621#issuecomment-2041650425 > There are quite a few test failures on

Re: [PR] KAFKA-16310 ListOffsets doesn't report the offset with maxTimestamp a… [kafka]

2024-04-07 Thread via GitHub
junrao commented on PR #15621: URL: https://github.com/apache/kafka/pull/15621#issuecomment-2041649750 @chia7712 : There are quite a few test failures on

Re: [PR] KAFKA-16477: Detect thread leaked client-metrics-reaper in tests [kafka]

2024-04-07 Thread via GitHub
chia7712 commented on code in PR #15668: URL: https://github.com/apache/kafka/pull/15668#discussion_r1555109656 ## server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java: ## @@ -112,7 +113,7 @@ public ClientMetricsManager(ClientMetricsReceiverPlugin

Re: [PR] KAFKA-16123: KStreamKStreamJoinProcessor does not drop late records. [kafka]

2024-04-07 Thread via GitHub
florin-akermann commented on PR #15189: URL: https://github.com/apache/kafka/pull/15189#issuecomment-2041579829 Hi @mjsax It's now rebased. Plus, I addressed your reply below. > If find this test a little bit hard to follow... > > We start to open a window `[5;15]` with

Re: [PR] KAFKA-16436: Online upgrade triggering and group type conversion [kafka]

2024-04-07 Thread via GitHub
dongnuo123 commented on code in PR #15662: URL: https://github.com/apache/kafka/pull/15662#discussion_r1555022535 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java: ## @@ -1300,6 +1341,68 @@ public Map groupAssignment() {

Re: [PR] KAFKA-16436: Online upgrade triggering and group type conversion [kafka]

2024-04-07 Thread via GitHub
dongnuo123 commented on code in PR #15662: URL: https://github.com/apache/kafka/pull/15662#discussion_r1555022109 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java: ## @@ -1300,6 +1341,68 @@ public Map groupAssignment() {

Re: [PR] KAFKA-16436: Online upgrade triggering and group type conversion [kafka]

2024-04-07 Thread via GitHub
dongnuo123 commented on code in PR #15662: URL: https://github.com/apache/kafka/pull/15662#discussion_r1555021412 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java: ## @@ -1244,6 +1267,24 @@ public boolean completeSyncFuture(

Re: [PR] MINOR: Add type check to classic group timeout operations [kafka]

2024-04-07 Thread via GitHub
dongnuo123 commented on code in PR #15587: URL: https://github.com/apache/kafka/pull/15587#discussion_r1555019741 ## group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java: ## @@ -2415,6 +2415,20 @@ private CoordinatorResult

Re: [PR] KAFKA-16297: Race condition while promoting future replica [kafka]

2024-04-07 Thread via GitHub
soarez commented on PR #15557: URL: https://github.com/apache/kafka/pull/15557#issuecomment-2041535672 I think I've addressed the issues. The failing tests on the most recent build are unrelated. PTAL @showuon -- This is an automated message from the Apache Git Service. To respond to

Re: [PR] KAFKA-16477: Detect thread leaked client-metrics-reaper in tests [kafka]

2024-04-07 Thread via GitHub
brandboat commented on code in PR #15668: URL: https://github.com/apache/kafka/pull/15668#discussion_r1554997766 ## server-common/src/test/java/org/apache/kafka/server/util/timer/TimerTest.java: ## @@ -77,7 +77,7 @@ public void setup() { @AfterEach public void

Re: [PR] KAFKA-16477: Detect thread leaked client-metrics-reaper in tests [kafka]

2024-04-07 Thread via GitHub
chia7712 commented on code in PR #15668: URL: https://github.com/apache/kafka/pull/15668#discussion_r1554997443 ## server-common/src/test/java/org/apache/kafka/server/util/timer/TimerTest.java: ## @@ -77,7 +77,7 @@ public void setup() { @AfterEach public void

[jira] [Assigned] (KAFKA-16484) Support to define per broker/controller property by ClusterConfigProperty

2024-04-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-16484: -- Assignee: Kuan Po Tseng (was: Chia-Ping Tsai) > Support to define per

[jira] [Commented] (KAFKA-16484) Support to define per broker/controller property by ClusterConfigProperty

2024-04-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834692#comment-17834692 ] Chia-Ping Tsai commented on KAFKA-16484: [~brandboat] I'm not working on this, so please feel

[jira] [Comment Edited] (KAFKA-16484) Support to define per broker/controller property by ClusterConfigProperty

2024-04-07 Thread Kuan Po Tseng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834690#comment-17834690 ] Kuan Po Tseng edited comment on KAFKA-16484 at 4/7/24 3:14 PM: --- Hello

[jira] [Commented] (KAFKA-16484) Support to define per broker/controller property by ClusterConfigProperty

2024-04-07 Thread Kuan Po Tseng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834690#comment-17834690 ] Kuan Po Tseng commented on KAFKA-16484: --- Hello [~chia7712], I'm willing to take over this issue,

[jira] [Created] (KAFKA-16484) Support to define per broker property by ClusterConfigProperty

2024-04-07 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16484: -- Summary: Support to define per broker property by ClusterConfigProperty Key: KAFKA-16484 URL: https://issues.apache.org/jira/browse/KAFKA-16484 Project: Kafka

[jira] [Updated] (KAFKA-16484) Support to define per broker/controller property by ClusterConfigProperty

2024-04-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-16484: --- Summary: Support to define per broker/controller property by ClusterConfigProperty (was:

Re: [PR] MINOR: enable kraft test for ReassignPartitionsIntegrationTest [kafka]

2024-04-07 Thread via GitHub
FrankYang0529 commented on PR #15675: URL: https://github.com/apache/kafka/pull/15675#issuecomment-2041482907 > @FrankYang0529 Could we use `ClusterTestExtensions` to enable `kraft`? It seems to me that using the new test framework is the better way. Otherwise, we may rewrite it again in

Re: [PR] MINOR: enable kraft test for ReassignPartitionsIntegrationTest [kafka]

2024-04-07 Thread via GitHub
chia7712 commented on PR #15675: URL: https://github.com/apache/kafka/pull/15675#issuecomment-2041482458 @FrankYang0529 Could we use `ClusterTestExtensions` to enable `kraft`? It seems to me that using the new test framework is the better way. Otherwise, we may rewrite it again in the

[PR] MINOR: enable kraft test for ReassignPartitionsIntegrationTest [kafka]

2024-04-07 Thread via GitHub
FrankYang0529 opened a new pull request, #15675: URL: https://github.com/apache/kafka/pull/15675 Enable Kraft test for `ReassignPartitionsIntegrationTest`. All test cases can pass on my laptop. ### Committer Checklist (excluded from commit message) - [ ] Verify design and

Re: [PR] KAFKA-13907: Fix hanging ServerShutdownTest.testCleanShutdownWithKRaftControllerUnavailable [kafka]

2024-04-07 Thread via GitHub
chia7712 commented on PR #12174: URL: https://github.com/apache/kafka/pull/12174#issuecomment-2041478299 @soarez Could you please fix the conflicts? thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] MINOR: Default test name added to core [kafka]

2024-04-07 Thread via GitHub
chia7712 merged PR #15667: URL: https://github.com/apache/kafka/pull/15667 -- 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] MINOR: Default test name added to tools [kafka]

2024-04-07 Thread via GitHub
chia7712 merged PR #15666: URL: https://github.com/apache/kafka/pull/15666 -- 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] MINOR: Cleanup in MetadataShell [kafka]

2024-04-07 Thread via GitHub
chia7712 commented on code in PR #15672: URL: https://github.com/apache/kafka/pull/15672#discussion_r1554976395 ## shell/src/main/java/org/apache/kafka/shell/MetadataShell.java: ## @@ -281,13 +278,12 @@ public static void main(String[] args) throws Exception { } }

Re: [PR] KAFKA-16477: Detect thread leaked client-metrics-reaper in tests [kafka]

2024-04-07 Thread via GitHub
chia7712 commented on code in PR #15668: URL: https://github.com/apache/kafka/pull/15668#discussion_r1554964050 ## server-common/src/test/java/org/apache/kafka/server/util/timer/TimerTest.java: ## @@ -76,6 +77,7 @@ public void setup() { @AfterEach public void

[jira] [Commented] (KAFKA-16483) Apply `ClusterTestExtensions` to DeleteOffsetsConsumerGroupCommandIntegrationTest

2024-04-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834675#comment-17834675 ] Chia-Ping Tsai commented on KAFKA-16483: sure. I have assigned this to you [~yangpoan]  > Apply

[jira] [Assigned] (KAFKA-16483) Apply `ClusterTestExtensions` to DeleteOffsetsConsumerGroupCommandIntegrationTest

2024-04-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-16483: -- Assignee: PoAn Yang (was: Chia-Ping Tsai) > Apply `ClusterTestExtensions` to >

[jira] [Commented] (KAFKA-16483) Apply `ClusterTestExtensions` to DeleteOffsetsConsumerGroupCommandIntegrationTest

2024-04-07 Thread PoAn Yang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834674#comment-17834674 ] PoAn Yang commented on KAFKA-16483: --- Hi [~chia7712], I'm interested in this. May I assign to myself?

[jira] [Created] (KAFKA-16483) Apply `ClusterTestExtensions` to DeleteOffsetsConsumerGroupCommandIntegrationTest

2024-04-07 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16483: -- Summary: Apply `ClusterTestExtensions` to DeleteOffsetsConsumerGroupCommandIntegrationTest Key: KAFKA-16483 URL: https://issues.apache.org/jira/browse/KAFKA-16483

Re: [PR] KAFKA-16477: Detect thread leaked client-metrics-reaper in tests [kafka]

2024-04-07 Thread via GitHub
brandboat commented on code in PR #15668: URL: https://github.com/apache/kafka/pull/15668#discussion_r1554955481 ## server-common/src/test/java/org/apache/kafka/server/util/timer/SystemTimerReaperTest.java: ## @@ -59,4 +59,11 @@ public void testReaper() throws Exception {

[jira] [Updated] (KAFKA-16482) Avoid changing ClusterConfig in `BeforeEach` phase

2024-04-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-16482: --- Description: IDE does not like the code style, and we can leverage `ClusterConfigProperty`

[jira] [Commented] (KAFKA-16482) Avoid changing ClusterConfig in `BeforeEach` phase

2024-04-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834663#comment-17834663 ] Chia-Ping Tsai commented on KAFKA-16482: sure. go ahead > Avoid changing ClusterConfig in

[jira] [Assigned] (KAFKA-16482) Avoid changing ClusterConfig in `BeforeEach` phase

2024-04-07 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-16482: -- Assignee: Cheng-Kai, Zhang (was: Chia-Ping Tsai) > Avoid changing ClusterConfig in

[jira] [Commented] (KAFKA-16482) Avoid changing ClusterConfig in `BeforeEach` phase

2024-04-07 Thread Cheng-Kai, Zhang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834662#comment-17834662 ] Cheng-Kai, Zhang commented on KAFKA-16482: -- I am interested to this issue, could you assign it

[jira] [Created] (KAFKA-16482) Avoid changing ClusterConfig in `BeforeEach` phase

2024-04-07 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-16482: -- Summary: Avoid changing ClusterConfig in `BeforeEach` phase Key: KAFKA-16482 URL: https://issues.apache.org/jira/browse/KAFKA-16482 Project: Kafka Issue

[PR] Fix usage of none in javadoc [kafka]

2024-04-07 Thread via GitHub
erikvanoosten opened a new pull request, #15674: URL: https://github.com/apache/kafka/pull/15674 - Use `Empty` instead of 'none' when referring to `Optional` values. - `Headers.lastHeader` returns `null` when no header is found. - Fix minor spelling mistakes. ### Committer

Re: [PR] Fix usage of none in javadoc [kafka]

2024-04-07 Thread via GitHub
erikvanoosten commented on PR #15674: URL: https://github.com/apache/kafka/pull/15674#issuecomment-2041343908 I am a big fan of scala, but 'some' and 'none' are not the terminology used in the java world. This PR does not change any code, only javadoc. -- This is an automated message