[jira] [Assigned] (KAFKA-17586) AsyncKafkaConsumer#seek should NOT wait the completion of backgound

2024-09-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-17586: -- Assignee: TaiJuWu (was: Chia-Ping Tsai) > AsyncKafkaConsumer#seek should NOT wait th

[jira] [Commented] (KAFKA-17586) AsyncKafkaConsumer#seek should NOT wait the completion of backgound

2024-09-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883712#comment-17883712 ] Chia-Ping Tsai commented on KAFKA-17586: [~goyarpit] Sorry that we are still dis

Re: [PR] KAFKA-17570: Rewrite StressTestLog by JMH [kafka]

2024-09-22 Thread via GitHub
chia7712 commented on code in PR #17249: URL: https://github.com/apache/kafka/pull/17249#discussion_r1770840515 ## jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/StressTestLog.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or

Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]

2024-09-22 Thread via GitHub
frankvicky commented on code in PR #17250: URL: https://github.com/apache/kafka/pull/17250#discussion_r1770804334 ## tests/kafkatest/tests/core/reassign_partitions_test.py: ## @@ -176,7 +176,7 @@ def test_reassign_partitions(self, bounce_brokers, reassign_from_offset_zero, me

Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]

2024-09-22 Thread via GitHub
frankvicky commented on PR #17250: URL: https://github.com/apache/kafka/pull/17250#issuecomment-2367291581 Hello @chia7712 Following is the test result on branch 3.8: ``` SESSION REPORT (ALL TESTS)

[jira] [Commented] (KAFKA-17586) AsyncKafkaConsumer#seek should NOT wait the completion of backgound

2024-09-22 Thread Arpit Goyal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883684#comment-17883684 ] Arpit Goyal commented on KAFKA-17586: - [~chia7712] Can i pick this ? > AsyncKafkaCo

Re: [PR] KAFKA-17530: Remove blacklist/whitelist from ReplaceField [kafka]

2024-09-22 Thread via GitHub
TaiJuWu commented on PR #17237: URL: https://github.com/apache/kafka/pull/17237#issuecomment-2367247213 > @TaiJuWu Could you please fix conflicts? Done. Thanks for review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] KAFKA-17530: Remove blacklist/whitelist from ReplaceField [kafka]

2024-09-22 Thread via GitHub
chia7712 commented on PR #17237: URL: https://github.com/apache/kafka/pull/17237#issuecomment-2367182725 @TaiJuWu Could you please fix conflicts? -- 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 t

Re: [PR] MINOR: fixing JavaDocs and other cleanup [kafka]

2024-09-22 Thread via GitHub
chia7712 merged PR #17207: URL: https://github.com/apache/kafka/pull/17207 -- 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-16331: remove EOSv1 from StreamsProducer [kafka]

2024-09-22 Thread via GitHub
chia7712 merged PR #17212: URL: https://github.com/apache/kafka/pull/17212 -- 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-17459: Stablize reassign_partitions_test.py [kafka]

2024-09-22 Thread via GitHub
chia7712 commented on code in PR #17250: URL: https://github.com/apache/kafka/pull/17250#discussion_r1770737046 ## tests/kafkatest/tests/core/reassign_partitions_test.py: ## @@ -176,7 +176,7 @@ def test_reassign_partitions(self, bounce_brokers, reassign_from_offset_zero, me

[jira] [Resolved] (KAFKA-17528) Remove whitelist/blacklist from JMXReporter

2024-09-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17528. Fix Version/s: 4.0.0 Resolution: Fixed > Remove whitelist/blacklist from JMXReporte

Re: [PR] KAFKA-17528: Remove whitelist/blacklist from JMXReporter [kafka]

2024-09-22 Thread via GitHub
chia7712 merged PR #17179: URL: https://github.com/apache/kafka/pull/17179 -- 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] [Updated] (KAFKA-17459) Stabilize reassign_partitions_test.py

2024-09-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17459: --- Priority: Major (was: Blocker) > Stabilize reassign_partitions_test.py > --

[jira] [Updated] (KAFKA-17459) Stabilize reassign_partitions_test.py

2024-09-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17459: --- Fix Version/s: 3.9.1 3.8.1 > Stabilize reassign_partitions_test.py >

Re: [PR] KAFKA-17529: Remove blacklist from MM2 [kafka]

2024-09-22 Thread via GitHub
chia7712 commented on code in PR #17202: URL: https://github.com/apache/kafka/pull/17202#discussion_r1770733451 ## docs/upgrade.html: ## @@ -51,6 +51,18 @@ Notable changes in 4 The --whitelist option was removed from the kafka-console-consumer command line tool

[jira] [Commented] (KAFKA-17551) Remove ForeachProcessor

2024-09-22 Thread Chia-Chuan Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883651#comment-17883651 ] Chia-Chuan Yu commented on KAFKA-17551: --- Got it, thanks for the reminder! > Remov

Re: [PR] KAFKA-17512: Move LogSegmentTest to storage module [kafka]

2024-09-22 Thread via GitHub
xijiu commented on PR #17174: URL: https://github.com/apache/kafka/pull/17174#issuecomment-2367091855 @chia7712 Inlining does make the code more cleaner. I have fixed it, PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] KAFKA-17540: Create floating tag on trunk for CI cache [kafka]

2024-09-22 Thread via GitHub
fonsdant commented on PR #17204: URL: https://github.com/apache/kafka/pull/17204#issuecomment-2366967094 How about using only a ref to point to the cached commit instead? A tag isn't the best option, as described in the GitHub REST API documentation: _"A Git tag is similar to a Git re

[jira] [Commented] (KAFKA-17551) Remove ForeachProcessor

2024-09-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883631#comment-17883631 ] Matthias J. Sax commented on KAFKA-17551: - Thanks for your interest to contribut

Re: [PR] KAFKA-17524: Add timeout to StreamThreadTest.shouldReturnErrorIfProducerInstanceIdNotInitialized [kafka]

2024-09-22 Thread via GitHub
mjsax closed pull request #17167: KAFKA-17524: Add timeout to StreamThreadTest.shouldReturnErrorIfProducerInstanceIdNotInitialized URL: https://github.com/apache/kafka/pull/17167 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[jira] [Commented] (KAFKA-16619) Unnecessary controller warning : "Loaded ZK migration state of NONE"

2024-09-22 Thread Rohit Pandey (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883623#comment-17883623 ] Rohit Pandey commented on KAFKA-16619: -- Please mark this task as resolved > Unnece

[jira] [Commented] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support

2024-09-22 Thread Rohit Pandey (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883621#comment-17883621 ] Rohit Pandey commented on KAFKA-7062: - If MirrorMaker 2.0 ([KIP-382|https://cwiki.ap

Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]

2024-09-22 Thread via GitHub
frankvicky commented on PR #17250: URL: https://github.com/apache/kafka/pull/17250#issuecomment-2366844405 Test result on my local machine ``` SESSION REPORT (ALL TESTS) ducktape version: 0.11.4 s

[jira] [Commented] (KAFKA-17581) AsyncKafkaConsumer can't unsubscribe invalid topics

2024-09-22 Thread PoAn Yang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883614#comment-17883614 ] PoAn Yang commented on KAFKA-17581: --- Hi [~kirktrue], here is related Jira and PR: * h

[jira] [Commented] (KAFKA-17581) AsyncKafkaConsumer can't unsubscribe invalid topics

2024-09-22 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883613#comment-17883613 ] Kirk True commented on KAFKA-17581: --- [~yangpoan]—this is a good catch! Where in the ne

[jira] [Commented] (KAFKA-17588) Remove internal classes from ClusterInstance

2024-09-22 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883608#comment-17883608 ] David Arthur commented on KAFKA-17588: -- Yes, TestUtils.scala presents some problems

[PR] [WIP] KAFKA-16974 Support to create a quorum controller which is not in cluster [kafka]

2024-09-22 Thread via GitHub
brandboat opened a new pull request, #17251: URL: https://github.com/apache/kafka/pull/17251 related to https://issues.apache.org/jira/browse/KAFKA-16974?filter=12353520 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify te

[PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]

2024-09-22 Thread via GitHub
frankvicky opened a new pull request, #17250: URL: https://github.com/apache/kafka/pull/17250 JIRA: [KAFKA-17459](https://issues.apache.org/jira/browse/KAFKA-17459) ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test co

[jira] [Updated] (KAFKA-17459) Stabilize reassign_partitions_test.py

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

[jira] [Updated] (KAFKA-17459) Stabilize reassign_partitions_test.py

2024-09-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-17459: --- Summary: Stabilize reassign_partitions_test.py (was: Stabalize reassign_partitions_test.py)

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

2024-09-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883592#comment-17883592 ] Chia-Ping Tsai commented on KAFKA-17459: The root cause is `reassign_partitions_

[PR] KAFKA-17570: Rewrite StressTestLog by JMH [kafka]

2024-09-22 Thread via GitHub
frankvicky opened a new pull request, #17249: URL: https://github.com/apache/kafka/pull/17249 JIRA: [KAFKA-17570](https://issues.apache.org/jira/browse/KAFKA-17570) ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test co

Re: [PR] MINOR: validate ReplaceField config [kafka]

2024-09-22 Thread via GitHub
TaiJuWu commented on code in PR #17247: URL: https://github.com/apache/kafka/pull/17247#discussion_r1770233963 ## connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java: ## @@ -78,6 +79,10 @@ interface ConfigName { .define(ConfigName.

[jira] [Commented] (KAFKA-15528) KIP-986: Cross-Cluster Replication

2024-09-22 Thread Jiashen Zhang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883577#comment-17883577 ] Jiashen Zhang commented on KAFKA-15528: --- Hey [~gharris] , I am [Jiashen Zhang|htt

Re: [PR] MINOR: validate ReplaceField config [kafka]

2024-09-22 Thread via GitHub
m1a2st commented on code in PR #17247: URL: https://github.com/apache/kafka/pull/17247#discussion_r1770153629 ## connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java: ## @@ -95,6 +100,9 @@ public String version() { @Override public v

[jira] [Commented] (KAFKA-17588) Remove internal classes from ClusterInstance

2024-09-22 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883575#comment-17883575 ] Chia-Ping Tsai commented on KAFKA-17588: Some internal classes are used to check

[jira] [Commented] (KAFKA-17551) Remove ForeachProcessor

2024-09-22 Thread Chia-Chuan Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883573#comment-17883573 ] Chia-Chuan Yu commented on KAFKA-17551: --- Hi, [~mjsax]  if you're not working on t

[jira] [Commented] (KAFKA-17588) Remove internal classes from ClusterInstance

2024-09-22 Thread Chia-Chuan Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883571#comment-17883571 ] Chia-Chuan Yu commented on KAFKA-17588: --- Hi, [~davidarthur]  If you're not workin

[PR] KAFKA-17552: Handle LIST_OFFSETS request for max_timestamp when remote storage is enabled [kafka]

2024-09-22 Thread via GitHub
FrankYang0529 opened a new pull request, #17248: URL: https://github.com/apache/kafka/pull/17248 *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.* *Summ