[jira] [Assigned] (KAFKA-7952) Consider to switch to in-memory stores in test whenever possible

[ https://issues.apache.org/jira/browse/KAFKA-7952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-7952: - Assignee: Lorcan > Consider to switch to in-memory stores in test whenever possible > --

[jira] [Commented] (KAFKA-16875) Replace ClientState with TaskAssignment when creating individual consumer Assignments

[ https://issues.apache.org/jira/browse/KAFKA-16875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937689#comment-17937689 ] Lorcan commented on KAFKA-16875: Just posting the referenced PR where this post processi

[jira] [Assigned] (KAFKA-19022) Display cluster IDs being compared when encountering INCONSISTENT_CLUSTER_ID error

[ https://issues.apache.org/jira/browse/KAFKA-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-19022: -- Assignee: Lorcan > Display cluster IDs being compared when encountering INCONSISTENT_CLUSTER_ID > er

[jira] [Commented] (KAFKA-18054) Automatically detect missed configs needed by a topology

[ https://issues.apache.org/jira/browse/KAFKA-18054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938134#comment-17938134 ] Lorcan commented on KAFKA-18054: Hi [~cadonna], thanks for the additional insight. I th

[jira] [Assigned] (KAFKA-18054) Automatically detect missed configs needed by a topology

[ https://issues.apache.org/jira/browse/KAFKA-18054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-18054: -- Assignee: (was: Lorcan) > Automatically detect missed configs needed by a topology >

[jira] [Commented] (KAFKA-7952) Consider to switch to in-memory stores in test whenever possible

[ https://issues.apache.org/jira/browse/KAFKA-7952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936180#comment-17936180 ] Lorcan commented on KAFKA-7952: --- Hi [~mjsax] I have created a PR below with an approach tha

[jira] [Created] (KAFKA-19097) Fix order of arguments to assertEquals

Lorcan created KAFKA-19097: -- Summary: Fix order of arguments to assertEquals Key: KAFKA-19097 URL: https://issues.apache.org/jira/browse/KAFKA-19097 Project: Kafka Issue Type: Improvement

[jira] [Assigned] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-6629: - Assignee: Lorcan > SegmentedCacheFunctionTest does not cover session window serdes > ---

[jira] [Updated] (KAFKA-19097) Fix order of arguments to assertEquals

[ https://issues.apache.org/jira/browse/KAFKA-19097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan updated KAFKA-19097: --- Priority: Minor (was: Trivial) > Fix order of arguments to assertEquals > -

[jira] [Commented] (KAFKA-19097) Fix order of arguments to assertEquals

[ https://issues.apache.org/jira/browse/KAFKA-19097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941349#comment-17941349 ] Lorcan commented on KAFKA-19097: Hi [~apalan60], yes feel free to assign yourself. I not

[jira] [Assigned] (KAFKA-19022) Display cluster IDs being compared when encountering INCONSISTENT_CLUSTER_ID error

[ https://issues.apache.org/jira/browse/KAFKA-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-19022: -- Assignee: (was: Lorcan) > Display cluster IDs being compared when encountering INCONSISTENT_CLUST

[jira] [Assigned] (KAFKA-19070) Adding task number to the user provided client id (via consumer.override.client.id) to ensure each consumer has a unique client ID to avoid metric registration conflict

[ https://issues.apache.org/jira/browse/KAFKA-19070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-19070: -- Assignee: Lorcan > Adding task number to the user provided client id (via > consumer.override.client

[jira] [Commented] (KAFKA-19022) Display cluster IDs being compared when encountering INCONSISTENT_CLUSTER_ID error

[ https://issues.apache.org/jira/browse/KAFKA-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938478#comment-17938478 ] Lorcan commented on KAFKA-19022: Hi [~rsamudrala], I've checked the KafkaRaftClient clas

[jira] [Commented] (KAFKA-19022) Display cluster IDs being compared when encountering INCONSISTENT_CLUSTER_ID error

[ https://issues.apache.org/jira/browse/KAFKA-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938509#comment-17938509 ] Lorcan commented on KAFKA-19022: Upon further investigation and reading the file FetchRe

[jira] [Comment Edited] (KAFKA-19022) Display cluster IDs being compared when encountering INCONSISTENT_CLUSTER_ID error

[ https://issues.apache.org/jira/browse/KAFKA-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938478#comment-17938478 ] Lorcan edited comment on KAFKA-19022 at 3/26/25 8:20 AM: - Hi [~r

[jira] [Assigned] (KAFKA-9904) Use ThreadLocalConcurrent to Replace Random

[ https://issues.apache.org/jira/browse/KAFKA-9904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-9904: - Assignee: Lorcan > Use ThreadLocalConcurrent to Replace Random > ---

[jira] [Commented] (KAFKA-9904) Use ThreadLocalConcurrent to Replace Random

[ https://issues.apache.org/jira/browse/KAFKA-9904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939012#comment-17939012 ] Lorcan commented on KAFKA-9904: --- Hi [~belugabehr], is this something that you'd advise shou

[jira] [Commented] (KAFKA-15873) Improve the performance of the DescribeTopicPartitions API

[ https://issues.apache.org/jira/browse/KAFKA-15873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939136#comment-17939136 ] Lorcan commented on KAFKA-15873: Hi [~calvinliu], I've created a minor patch that addres

[jira] [Assigned] (KAFKA-16869) Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-16869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-16869: -- Assignee: Lorcan > Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor > interfac

[jira] [Commented] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941541#comment-17941541 ] Lorcan commented on KAFKA-6629: --- Hi [~guozhang], I've created a PR for this change: https:

[jira] [Assigned] (KAFKA-16869) Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-16869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-16869: -- Assignee: (was: Lorcan) > Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor

[jira] [Commented] (KAFKA-13555) Consider number if input topic partitions for task assignment

[ https://issues.apache.org/jira/browse/KAFKA-13555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949627#comment-17949627 ] Lorcan commented on KAFKA-13555: Hi [~mjsax], I have made some progress with this ticket

[jira] [Assigned] (KAFKA-13555) Consider number if input topic partitions for task assignment

[ https://issues.apache.org/jira/browse/KAFKA-13555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-13555: -- Assignee: Lorcan > Consider number if input topic partitions for task assignment > --

[jira] [Commented] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928166#comment-17928166 ] Lorcan commented on KAFKA-4650: --- Hi [~damianguy], [~mjsax], I have created a PR for some un

[jira] [Commented] (KAFKA-18912) Failed test MetadataSchemaCheckerToolTest.testVerifyEvolutionGit on Trunk

[ https://issues.apache.org/jira/browse/KAFKA-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931961#comment-17931961 ] Lorcan commented on KAFKA-18912: Hi [~chia7712], thanks for the information, I wasn't aw

[jira] [Created] (KAFKA-18912) Failed test MetadataSchemaCheckerToolTest.testVerifyEvolutionGit on Trunk

Lorcan created KAFKA-18912: -- Summary: Failed test MetadataSchemaCheckerToolTest.testVerifyEvolutionGit on Trunk Key: KAFKA-18912 URL: https://issues.apache.org/jira/browse/KAFKA-18912 Project: Kafka

[jira] [Updated] (KAFKA-18912) Failed test MetadataSchemaCheckerToolTest.testVerifyEvolutionGit on Trunk

[ https://issues.apache.org/jira/browse/KAFKA-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan updated KAFKA-18912: --- Description: I am unable to build (up to date as of 03/03) trunk with no local changes due to a failed test

[jira] [Assigned] (KAFKA-16616) refactor mergeWith in MetadataSnapshot

[ https://issues.apache.org/jira/browse/KAFKA-16616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-16616: -- Assignee: Lorcan > refactor mergeWith in MetadataSnapshot > -- >

[jira] [Commented] (KAFKA-16616) refactor mergeWith in MetadataSnapshot

[ https://issues.apache.org/jira/browse/KAFKA-16616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17935210#comment-17935210 ] Lorcan commented on KAFKA-16616: Hi [~alyssahuang], I have submitted a PR for this issue

[jira] [Commented] (KAFKA-18054) Automatically detect missed configs needed by a topology

[ https://issues.apache.org/jira/browse/KAFKA-18054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932736#comment-17932736 ] Lorcan commented on KAFKA-18054: Hi [~ableegoldman], I’ve done some investigation into t

[jira] [Assigned] (KAFKA-18054) Automatically detect missed configs needed by a topology

[ https://issues.apache.org/jira/browse/KAFKA-18054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-18054: -- Assignee: Lorcan > Automatically detect missed configs needed by a topology > ---

[jira] [Commented] (KAFKA-19022) Display cluster IDs being compared when encountering INCONSISTENT_CLUSTER_ID error

[ https://issues.apache.org/jira/browse/KAFKA-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940710#comment-17940710 ] Lorcan commented on KAFKA-19022: I am not sure about the KIP process as I'm quite new to

[jira] [Commented] (KAFKA-13555) Consider number if input topic partitions for task assignment

[ https://issues.apache.org/jira/browse/KAFKA-13555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17950712#comment-17950712 ] Lorcan commented on KAFKA-13555: Hi all, here's the PR link: [https://github.com/apache

[jira] [Comment Edited] (KAFKA-13555) Consider number if input topic partitions for task assignment

[ https://issues.apache.org/jira/browse/KAFKA-13555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17950712#comment-17950712 ] Lorcan edited comment on KAFKA-13555 at 5/10/25 7:02 PM: - Hi all

[jira] [Assigned] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-4650: - Assignee: (was: Lorcan) > Improve test coverage org.apache.kafka.streams.kstream.internals > ---

[jira] [Assigned] (KAFKA-19070) Adding task number to the user provided client id (via consumer.override.client.id) to ensure each consumer has a unique client ID to avoid metric registration conflict

[ https://issues.apache.org/jira/browse/KAFKA-19070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-19070: -- Assignee: (was: Lorcan) > Adding task number to the user provided client id (via > consumer.over

[jira] [Assigned] (KAFKA-9904) Use ThreadLocalConcurrent to Replace Random

[ https://issues.apache.org/jira/browse/KAFKA-9904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-9904: - Assignee: (was: Lorcan) > Use ThreadLocalConcurrent to Replace Random >

[jira] [Assigned] (KAFKA-16869) Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-16869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-16869: -- Assignee: Lorcan > Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor > interfac

[jira] [Commented] (KAFKA-16869) Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-16869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17956779#comment-17956779 ] Lorcan commented on KAFKA-16869: Hi [~ableegoldman], I've got a proof of concept of this

[jira] [Assigned] (KAFKA-13555) Consider number if input topic partitions for task assignment

[ https://issues.apache.org/jira/browse/KAFKA-13555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-13555: -- Assignee: (was: Lorcan) > Consider number if input topic partitions for task assignment > ---

[jira] [Assigned] (KAFKA-16869) Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-16869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorcan reassigned KAFKA-16869: -- Assignee: (was: Lorcan) > Rewrite HighAvailabilityTaskAssignor to implement the new TaskAssignor