[jira] [Assigned] (KAFKA-16828) RackAwareTaskAssignorTest failed

[ https://issues.apache.org/jira/browse/KAFKA-16828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng reassigned KAFKA-16828: - Assignee: Kuan Po Tseng > RackAwareTaskAssignorTest failed >

[jira] [Updated] (KAFKA-16795) Fix broken compatibility in kafka.tools.NoOpMessageFormatter, kafka.tools.DefaultMessageFormatter, and kafka.tools.LoggingMessageFormatter

[ https://issues.apache.org/jira/browse/KAFKA-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng updated KAFKA-16795: -- Parent: KAFKA-14525 Issue Type: Sub-task (was: Bug) > Fix broken compatibility in

[jira] [Created] (KAFKA-16795) Fix broken compatibility in kafka.tools.NoOpMessageFormatter, kafka.tools.DefaultMessageFormatter, and kafka.tools.LoggingMessageFormatter

Kuan Po Tseng created KAFKA-16795: - Summary: Fix broken compatibility in kafka.tools.NoOpMessageFormatter, kafka.tools.DefaultMessageFormatter, and kafka.tools.LoggingMessageFormatter Key: KAFKA-16795 URL:

[jira] [Created] (KAFKA-16794) Can't open videos in streams documentation

Kuan Po Tseng created KAFKA-16794: - Summary: Can't open videos in streams documentation Key: KAFKA-16794 URL: https://issues.apache.org/jira/browse/KAFKA-16794 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-16414) Inconsistent active segment expiration behavior between retention.ms and retention.bytes

[ https://issues.apache.org/jira/browse/KAFKA-16414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847617#comment-17847617 ] Kuan Po Tseng commented on KAFKA-16414: --- c.c. [~showuon] , any thoughts on this one ? Would be

[jira] [Commented] (KAFKA-16414) Inconsistent active segment expiration behavior between retention.ms and retention.bytes

[ https://issues.apache.org/jira/browse/KAFKA-16414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847616#comment-17847616 ] Kuan Po Tseng commented on KAFKA-16414: --- I'm still waiting for other Kafka PMC members/committers

[jira] [Commented] (KAFKA-16785) Migrate TopicBasedRemoteLogMetadataManagerRestartTest to new test infra

[ https://issues.apache.org/jira/browse/KAFKA-16785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847019#comment-17847019 ] Kuan Po Tseng commented on KAFKA-16785: --- May I take over this Jira ? > Migrate

[jira] [Resolved] (KAFKA-16595) Introduce ClusterTemplate in ClusterTests

[ https://issues.apache.org/jira/browse/KAFKA-16595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng resolved KAFKA-16595. --- Resolution: Won't Do As discussed in

[jira] [Updated] (KAFKA-16595) Introduce ClusterTemplate in ClusterTests

[ https://issues.apache.org/jira/browse/KAFKA-16595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng updated KAFKA-16595: -- Summary: Introduce ClusterTemplate in ClusterTests (was: Introduce template in ClusterTests)

[jira] [Commented] (KAFKA-16660) reduce the check interval to speedup DelegationTokenRequestsTest

[ https://issues.apache.org/jira/browse/KAFKA-16660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17843171#comment-17843171 ] Kuan Po Tseng commented on KAFKA-16660: --- I'm willing to work on this item ! May I take over this ?

[jira] [Commented] (KAFKA-16650) add integration test for Admin#abortTransaction

[ https://issues.apache.org/jira/browse/KAFKA-16650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842542#comment-17842542 ] Kuan Po Tseng commented on KAFKA-16650: --- May I take over this issue ? :) > add integration test

[jira] [Created] (KAFKA-16627) Remove ClusterConfig parameter in BeforeEach and AfterEach

Kuan Po Tseng created KAFKA-16627: - Summary: Remove ClusterConfig parameter in BeforeEach and AfterEach Key: KAFKA-16627 URL: https://issues.apache.org/jira/browse/KAFKA-16627 Project: Kafka

[jira] [Created] (KAFKA-16595) Introduce template in ClusterTests

Kuan Po Tseng created KAFKA-16595: - Summary: Introduce template in ClusterTests Key: KAFKA-16595 URL: https://issues.apache.org/jira/browse/KAFKA-16595 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-16560) Refactor/cleanup BrokerNode/ControllerNode/ClusterConfig

[ https://issues.apache.org/jira/browse/KAFKA-16560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837553#comment-17837553 ] Kuan Po Tseng commented on KAFKA-16560: --- Thanks [~chia7712], in

[jira] [Commented] (KAFKA-16552) Create an internal config to control InitialTaskDelayMs in LogManager to speed up tests

[ https://issues.apache.org/jira/browse/KAFKA-16552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837163#comment-17837163 ] Kuan Po Tseng commented on KAFKA-16552: --- +1 on this ! > Create an internal config to control

[jira] [Commented] (KAFKA-16544) DescribeTopicsResult#allTopicIds and DescribeTopicsResult#allTopicNames should return null instead of throwing NPE

[ https://issues.apache.org/jira/browse/KAFKA-16544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836797#comment-17836797 ] Kuan Po Tseng commented on KAFKA-16544: --- gentle ping [~chia7712], are you working on this one ?

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

[ 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

[ 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-16477) Detect thread leaked client-metrics-reaper in tests

Kuan Po Tseng created KAFKA-16477: - Summary: Detect thread leaked client-metrics-reaper in tests Key: KAFKA-16477 URL: https://issues.apache.org/jira/browse/KAFKA-16477 Project: Kafka Issue

[jira] [Commented] (KAFKA-16473) KafkaDockerWrapper uses wrong cluster ID when formatting log dir

[ https://issues.apache.org/jira/browse/KAFKA-16473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834001#comment-17834001 ] Kuan Po Tseng commented on KAFKA-16473: --- > I would appreciate a review of that PR, though. Sure,

[jira] [Commented] (KAFKA-16473) KafkaDockerWrapper uses wrong cluster ID when formatting log dir

[ https://issues.apache.org/jira/browse/KAFKA-16473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17833997#comment-17833997 ] Kuan Po Tseng commented on KAFKA-16473: --- Thank you for the detailed description. Are you planning

[jira] [Commented] (KAFKA-16472) Integration tests in Java don't really run kraft case

[ https://issues.apache.org/jira/browse/KAFKA-16472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17833990#comment-17833990 ] Kuan Po Tseng commented on KAFKA-16472: --- And the javadoc in junit5 also mentions that

[jira] [Commented] (KAFKA-16472) Integration tests in Java don't really run kraft case

[ https://issues.apache.org/jira/browse/KAFKA-16472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17833988#comment-17833988 ] Kuan Po Tseng commented on KAFKA-16472: --- Looks like

[jira] [Created] (KAFKA-16455) Check partition exists before send reassignments to server in ReassignPartitionsCommand

Kuan Po Tseng created KAFKA-16455: - Summary: Check partition exists before send reassignments to server in ReassignPartitionsCommand Key: KAFKA-16455 URL: https://issues.apache.org/jira/browse/KAFKA-16455

[jira] [Commented] (KAFKA-16435) Add test for KAFKA-16428

[ https://issues.apache.org/jira/browse/KAFKA-16435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831605#comment-17831605 ] Kuan Po Tseng commented on KAFKA-16435: --- I'm willing to take over this ! Let me add some test~

[jira] [Assigned] (KAFKA-16435) Add test for KAFKA-16428

[ https://issues.apache.org/jira/browse/KAFKA-16435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng reassigned KAFKA-16435: - Assignee: Kuan Po Tseng > Add test for KAFKA-16428 > > >

[jira] [Assigned] (KAFKA-16410) kafka-leader-election / LeaderElectionCommand doesn't set exit code on error

[ https://issues.apache.org/jira/browse/KAFKA-16410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng reassigned KAFKA-16410: - Assignee: Kuan Po Tseng > kafka-leader-election / LeaderElectionCommand doesn't set

[jira] [Commented] (KAFKA-16410) kafka-leader-election / LeaderElectionCommand doesn't set exit code on error

[ https://issues.apache.org/jira/browse/KAFKA-16410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830243#comment-17830243 ] Kuan Po Tseng commented on KAFKA-16410: --- Hi [~gharris1727] , I'm willing to take over this issue,

[jira] [Commented] (KAFKA-16385) Segment is rolled before segment.ms or segment.bytes breached

[ https://issues.apache.org/jira/browse/KAFKA-16385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830230#comment-17830230 ] Kuan Po Tseng commented on KAFKA-16385: --- Gentle ping [~chia7712], [~jeqo]. I've filed another JIRA

[jira] [Created] (KAFKA-16414) Inconsistent active segment expiration behavior between retention.ms and retention.bytes

Kuan Po Tseng created KAFKA-16414: - Summary: Inconsistent active segment expiration behavior between retention.ms and retention.bytes Key: KAFKA-16414 URL: https://issues.apache.org/jira/browse/KAFKA-16414

[jira] [Commented] (KAFKA-16385) Segment is rolled before segment.ms or segment.bytes breached

[ https://issues.apache.org/jira/browse/KAFKA-16385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830199#comment-17830199 ] Kuan Po Tseng commented on KAFKA-16385: --- {quote} I, as well, agree that we should include the

[jira] [Commented] (KAFKA-16385) Segment is rolled before segment.ms or segment.bytes breached

[ https://issues.apache.org/jira/browse/KAFKA-16385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828654#comment-17828654 ] Kuan Po Tseng commented on KAFKA-16385: --- {quote} [~brandboat] , are you clear what you should do

[jira] [Assigned] (KAFKA-16388) add production-ready test of 3.3 - 3.6 release to MetadataVersionTest.testFromVersionString

[ https://issues.apache.org/jira/browse/KAFKA-16388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng reassigned KAFKA-16388: - Assignee: Kuan Po Tseng > add production-ready test of 3.3 - 3.6 release to >

[jira] [Commented] (KAFKA-16388) add production-ready test of 3.3 - 3.6 release to MetadataVersionTest.testFromVersionString

[ https://issues.apache.org/jira/browse/KAFKA-16388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828542#comment-17828542 ] Kuan Po Tseng commented on KAFKA-16388: --- I'm willing to take over this~ Thanks ! > add

[jira] [Assigned] (KAFKA-16385) Segment is rolled before segment.ms or segment.bytes breached

[ https://issues.apache.org/jira/browse/KAFKA-16385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng reassigned KAFKA-16385: - Assignee: Kuan Po Tseng > Segment is rolled before segment.ms or segment.bytes

[jira] [Commented] (KAFKA-16385) Segment is rolled before segment.ms or segment.bytes breached

[ https://issues.apache.org/jira/browse/KAFKA-16385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828227#comment-17828227 ] Kuan Po Tseng commented on KAFKA-16385: --- I'm willing to take over this ! Many thanks ! > Segment

[jira] [Commented] (KAFKA-16376) Fix flaky ReplicaManagerTest.testRemoteFetchExpiresPerSecMetric

[ https://issues.apache.org/jira/browse/KAFKA-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827824#comment-17827824 ] Kuan Po Tseng commented on KAFKA-16376: --- Correct me if I'm wrong, but this appears to be a

[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback

[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827779#comment-17827779 ] Kuan Po Tseng commented on KAFKA-16263: --- May I take over this issue ? I'm quite interested in

[jira] [Commented] (KAFKA-16377) Fix flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

[ https://issues.apache.org/jira/browse/KAFKA-16377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827766#comment-17827766 ] Kuan Po Tseng commented on KAFKA-16377: --- I'm willing to take over this issue, many thanks ! > Fix

[jira] [Assigned] (KAFKA-16377) Fix flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

[ https://issues.apache.org/jira/browse/KAFKA-16377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng reassigned KAFKA-16377: - Assignee: Kuan Po Tseng > Fix flaky >

[jira] [Assigned] (KAFKA-16283) RoundRobinPartitioner will only send to half of the partitions in a topic

[ https://issues.apache.org/jira/browse/KAFKA-16283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan-Po Tseng reassigned KAFKA-16283: - Assignee: Kuan-Po Tseng > RoundRobinPartitioner will only send to half of the

[jira] [Assigned] (KAFKA-12187) replace assertTrue(obj instanceof X) by assertInstanceOf when we update to JUnit 5.8

[ https://issues.apache.org/jira/browse/KAFKA-12187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan-Po Tseng reassigned KAFKA-12187: - Assignee: Kuan-Po Tseng (was: Chia-Ping Tsai) > replace assertTrue(obj instanceof X)

[jira] [Commented] (KAFKA-16232) kafka hangs forever in the starting process if the authorizer future is not returned

[ https://issues.apache.org/jira/browse/KAFKA-16232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822739#comment-17822739 ] Kuan-Po Tseng commented on KAFKA-16232: --- Thank you [~showuon] , but I can't assign this issue to

[jira] [Commented] (KAFKA-16232) kafka hangs forever in the starting process if the authorizer future is not returned

[ https://issues.apache.org/jira/browse/KAFKA-16232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822532#comment-17822532 ] Kuan-Po Tseng commented on KAFKA-16232: --- gentle ping [~showuon] ~ I'm willing to take over this