[jira] [Commented] (KAFKA-16855) KRaft - Wire replaying a TopicRecord

[ https://issues.apache.org/jira/browse/KAFKA-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17865990#comment-17865990 ] Muralidhar Basani commented on KAFKA-16855: --- [~christo_lolov] thanks for the details. Will

[jira] [Commented] (KAFKA-16855) KRaft - Wire replaying a TopicRecord

[ https://issues.apache.org/jira/browse/KAFKA-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17865217#comment-17865217 ] Muralidhar Basani commented on KAFKA-16855: --- [~christo_lolov] can you pls provide some more

[jira] [Commented] (KAFKA-16855) KRaft - Wire replaying a TopicRecord

[ https://issues.apache.org/jira/browse/KAFKA-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17865191#comment-17865191 ] Muralidhar Basani commented on KAFKA-16855: --- [~showuon] sure. Will start looking into it. >

[jira] [Commented] (KAFKA-17080) bump metadata version for topic Record

[ https://issues.apache.org/jira/browse/KAFKA-17080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17863232#comment-17863232 ] Muralidhar Basani commented on KAFKA-17080: --- Thanks, will look at it. > bump metadata version

[jira] [Commented] (KAFKA-16936) Upgrade slf4k to 2.0.9 and integrate "-Dslf4j.provider" to kafka script

[ https://issues.apache.org/jira/browse/KAFKA-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17863046#comment-17863046 ] Muralidhar Basani commented on KAFKA-16936: --- We now have a kip

[jira] [Commented] (KAFKA-17080) bump metadata version for topic Record

[ https://issues.apache.org/jira/browse/KAFKA-17080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17863038#comment-17863038 ] Muralidhar Basani commented on KAFKA-17080: --- [~showuon] not sure how to bump this version. We

[jira] [Assigned] (KAFKA-17080) bump metadata version for topic Record

[ https://issues.apache.org/jira/browse/KAFKA-17080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muralidhar Basani reassigned KAFKA-17080: - Assignee: Muralidhar Basani > bump metadata version for topic Record >

[jira] [Commented] (KAFKA-17031) Make configurations public

[ https://issues.apache.org/jira/browse/KAFKA-17031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859942#comment-17859942 ] Muralidhar Basani commented on KAFKA-17031: --- I would like to pick this up later. > Make

[jira] [Commented] (KAFKA-17031) Make configurations public

[ https://issues.apache.org/jira/browse/KAFKA-17031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859837#comment-17859837 ] Muralidhar Basani commented on KAFKA-17031: --- Do we deprecate config

[jira] [Commented] (KAFKA-16855) KRaft - Wire replaying a TopicRecord

[ https://issues.apache.org/jira/browse/KAFKA-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856726#comment-17856726 ] Muralidhar Basani commented on KAFKA-16855: --- [~showuon] yes, I will look into part2 and also

[jira] [Commented] (KAFKA-16936) Upgrade slf4k to 2.0.9 and integrate "-Dslf4j.provider" to kafka script

[ https://issues.apache.org/jira/browse/KAFKA-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854254#comment-17854254 ] Muralidhar Basani commented on KAFKA-16936: --- [~chia7712] can I try looking at this, if you

[jira] [Comment Edited] (KAFKA-16855) KRaft - Wire replaying a TopicRecord

[ https://issues.apache.org/jira/browse/KAFKA-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853535#comment-17853535 ] Muralidhar Basani edited comment on KAFKA-16855 at 6/9/24 8:30 PM: ---

[jira] [Commented] (KAFKA-16855) KRaft - Wire replaying a TopicRecord

[ https://issues.apache.org/jira/browse/KAFKA-16855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853535#comment-17853535 ] Muralidhar Basani commented on KAFKA-16855: --- [~christo_lolov] I tried to work on this.

[jira] [Commented] (KAFKA-16919) Flaky test testNoCheckpointsIfNoRecordsAreMirrored() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest

[ https://issues.apache.org/jira/browse/KAFKA-16919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853511#comment-17853511 ] Muralidhar Basani commented on KAFKA-16919: --- [~soarez] I suspect there could be resource

[jira] [Assigned] (KAFKA-16922) add unit test for NewTopic

[ https://issues.apache.org/jira/browse/KAFKA-16922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muralidhar Basani reassigned KAFKA-16922: - Assignee: Muralidhar Basani (was: Chia-Ping Tsai) > add unit test for

[jira] [Commented] (KAFKA-16922) add unit test for NewTopic

[ https://issues.apache.org/jira/browse/KAFKA-16922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853438#comment-17853438 ] Muralidhar Basani commented on KAFKA-16922: --- [~chia7712] seems like there is no test file now.

[jira] [Assigned] (KAFKA-16863) Consider removing `default.` prefix for exception handler config

[ https://issues.apache.org/jira/browse/KAFKA-16863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muralidhar Basani reassigned KAFKA-16863: - Assignee: Muralidhar Basani > Consider removing `default.` prefix for

[jira] [Comment Edited] (KAFKA-16706) Refactor ReplicationQuotaManager/RLMQuotaManager to eliminate code duplication

[ https://issues.apache.org/jira/browse/KAFKA-16706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852802#comment-17852802 ] Muralidhar Basani edited comment on KAFKA-16706 at 6/6/24 2:06 PM: ---

[jira] [Commented] (KAFKA-16706) Refactor ReplicationQuotaManager/RLMQuotaManager to eliminate code duplication

[ https://issues.apache.org/jira/browse/KAFKA-16706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852802#comment-17852802 ] Muralidhar Basani commented on KAFKA-16706: --- Yes I see similarities. May be coming up with a

[jira] [Commented] (KAFKA-16863) Consider removing `default.` prefix for exception handler config

[ https://issues.apache.org/jira/browse/KAFKA-16863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852793#comment-17852793 ] Muralidhar Basani commented on KAFKA-16863: --- Do we need a kip for this config cleanup ? >From

[jira] (KAFKA-16856) Zookeeper - Add new exception

[ https://issues.apache.org/jira/browse/KAFKA-16856 ] Muralidhar Basani deleted comment on KAFKA-16856: --- was (Author: muralibasani): [~christo_lolov] I tried to create a PR for it. Can you pls take a look? > Zookeeper - Add new exception

[jira] [Commented] (KAFKA-16856) Zookeeper - Add new exception

[ https://issues.apache.org/jira/browse/KAFKA-16856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852693#comment-17852693 ] Muralidhar Basani commented on KAFKA-16856: --- [~christo_lolov] would you like to take a look at

[jira] (KAFKA-16856) Zookeeper - Add new exception

[ https://issues.apache.org/jira/browse/KAFKA-16856 ] Muralidhar Basani deleted comment on KAFKA-16856: --- was (Author: muralibasani): [~christo_lolov] possible to take a look at this one too ? > Zookeeper - Add new exception >

[jira] [Commented] (KAFKA-16884) Refactor RemoteLogManagerConfig with a Builder

[ https://issues.apache.org/jira/browse/KAFKA-16884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851809#comment-17851809 ] Muralidhar Basani commented on KAFKA-16884: --- [~gharris1727] agree with you about aligning it

[jira] [Created] (KAFKA-16884) Refactor RemoteLogManagerConfig with a Builder

Muralidhar Basani created KAFKA-16884: - Summary: Refactor RemoteLogManagerConfig with a Builder Key: KAFKA-16884 URL: https://issues.apache.org/jira/browse/KAFKA-16884 Project: Kafka

[jira] [Commented] (KAFKA-16880) Update equals and hashcode for two new *threadPool attributes

[ https://issues.apache.org/jira/browse/KAFKA-16880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851590#comment-17851590 ] Muralidhar Basani commented on KAFKA-16880: --- [~Kamal C] or [~clolov]  would you like to take a

[jira] [Comment Edited] (KAFKA-16880) Update equals and hashcode for two new *threadPool attributes

[ https://issues.apache.org/jira/browse/KAFKA-16880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851590#comment-17851590 ] Muralidhar Basani edited comment on KAFKA-16880 at 6/3/24 11:33 AM:

[jira] [Updated] (KAFKA-16880) Update equals and hashcode for two new *threadPool attributes

[ https://issues.apache.org/jira/browse/KAFKA-16880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muralidhar Basani updated KAFKA-16880: -- Description: Update equals and hashCode methods for the below in

[jira] [Created] (KAFKA-16880) Update equals and hashcode for two new *threadPool attributes

Muralidhar Basani created KAFKA-16880: - Summary: Update equals and hashcode for two new *threadPool attributes Key: KAFKA-16880 URL: https://issues.apache.org/jira/browse/KAFKA-16880 Project:

[jira] [Assigned] (KAFKA-16880) Update equals and hashcode for two new *threadPool attributes

[ https://issues.apache.org/jira/browse/KAFKA-16880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muralidhar Basani reassigned KAFKA-16880: - Assignee: Muralidhar Basani > Update equals and hashcode for two new

[jira] [Comment Edited] (KAFKA-16698) Fix flaky kafka.network.DynamicConnectionQuotaTest#testDynamicIpConnectionRateQuota

[ https://issues.apache.org/jira/browse/KAFKA-16698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851343#comment-17851343 ] Muralidhar Basani edited comment on KAFKA-16698 at 6/1/24 9:36 PM: ---

[jira] [Commented] (KAFKA-16698) Fix flaky kafka.network.DynamicConnectionQuotaTest#testDynamicIpConnectionRateQuota

[ https://issues.apache.org/jira/browse/KAFKA-16698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851343#comment-17851343 ] Muralidhar Basani commented on KAFKA-16698: --- Thanks, I have a PR opened. > Fix flaky >

[jira] [Assigned] (KAFKA-16698) Fix flaky kafka.network.DynamicConnectionQuotaTest#testDynamicIpConnectionRateQuota

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

[jira] [Commented] (KAFKA-16874) Remove old TaskAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-16874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851342#comment-17851342 ] Muralidhar Basani commented on KAFKA-16874: --- I see there are a few other implementations for

[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=17851341#comment-17851341 ] Muralidhar Basani commented on KAFKA-16869: --- Is it ok if I pick up this ?  With the reference

[jira] [Commented] (KAFKA-16698) Fix flaky kafka.network.DynamicConnectionQuotaTest#testDynamicIpConnectionRateQuota

[ https://issues.apache.org/jira/browse/KAFKA-16698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851128#comment-17851128 ] Muralidhar Basani commented on KAFKA-16698: --- For ex : in this method updateIpConnectionRate,

[jira] [Commented] (KAFKA-16856) Zookeeper - Add new exception

[ https://issues.apache.org/jira/browse/KAFKA-16856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851127#comment-17851127 ] Muralidhar Basani commented on KAFKA-16856: --- [~christo_lolov] possible to take a look at this

[jira] [Commented] (KAFKA-16698) Fix flaky kafka.network.DynamicConnectionQuotaTest#testDynamicIpConnectionRateQuota

[ https://issues.apache.org/jira/browse/KAFKA-16698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851102#comment-17851102 ] Muralidhar Basani commented on KAFKA-16698: --- [~chia7712] similar to other flaky tests, all are

[jira] [Commented] (KAFKA-16775) Fix flaky PlaintextAdminIntegrationTest#testCreateExistingTopicsThrowTopicExistsException

[ https://issues.apache.org/jira/browse/KAFKA-16775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851099#comment-17851099 ] Muralidhar Basani commented on KAFKA-16775: --- [~chia7712] currently the wait time [defined

[jira] [Comment Edited] (KAFKA-16852) Add *.thread.pool.size

[ https://issues.apache.org/jira/browse/KAFKA-16852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851062#comment-17851062 ] Muralidhar Basani edited comment on KAFKA-16852 at 5/31/24 12:22 PM: -

[jira] [Commented] (KAFKA-16852) Add *.thread.pool.size

[ https://issues.apache.org/jira/browse/KAFKA-16852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851062#comment-17851062 ] Muralidhar Basani commented on KAFKA-16852: --- I have a PR open. Can you pls take a look. I have

[jira] [Comment Edited] (KAFKA-16852) Add *.thread.pool.size

[ https://issues.apache.org/jira/browse/KAFKA-16852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851015#comment-17851015 ] Muralidhar Basani edited comment on KAFKA-16852 at 5/31/24 9:25 AM:

[jira] [Commented] (KAFKA-16852) Add *.thread.pool.size

[ https://issues.apache.org/jira/browse/KAFKA-16852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851015#comment-17851015 ] Muralidhar Basani commented on KAFKA-16852: --- [~christo_lolov] few questions. * do we also

[jira] [Commented] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17850851#comment-17850851 ] Muralidhar Basani commented on KAFKA-16518: --- [~jsancio] have one short question in the pr

[jira] [Commented] (KAFKA-16856) Zookeeper - Add new exception

[ https://issues.apache.org/jira/browse/KAFKA-16856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17850728#comment-17850728 ] Muralidhar Basani commented on KAFKA-16856: --- [~christo_lolov] I tried to create a PR for it.

[jira] [Commented] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured

[ https://issues.apache.org/jira/browse/KAFKA-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849991#comment-17849991 ] Muralidhar Basani commented on KAFKA-16790: --- [~christo_lolov] [~nikramakrishnan]  wdyt about

[jira] [Commented] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849795#comment-17849795 ] Muralidhar Basani commented on KAFKA-16518: --- [~jsancio] have a new PR

[jira] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518 ] Muralidhar Basani deleted comment on KAFKA-16518: --- was (Author: muralibasani): https://github.com/apache/kafka/pull/16094 > Storage tool changes for KIP-853 >

[jira] [Commented] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849794#comment-17849794 ] Muralidhar Basani commented on KAFKA-16518: --- https://github.com/apache/kafka/pull/16094 >

[jira] [Comment Edited] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849361#comment-17849361 ] Muralidhar Basani edited comment on KAFKA-16518 at 5/24/24 6:22 PM:

[jira] [Commented] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849361#comment-17849361 ] Muralidhar Basani commented on KAFKA-16518: --- Hi [~jsancio] I see it has to be extended under

[jira] [Commented] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849236#comment-17849236 ] Muralidhar Basani commented on KAFKA-16518: --- [~jsancio] have a draft pr opened for adding

[jira] [Assigned] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muralidhar Basani reassigned KAFKA-16518: - Assignee: Muralidhar Basani > Storage tool changes for KIP-853 >

[jira] [Comment Edited] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848839#comment-17848839 ] Muralidhar Basani edited comment on KAFKA-16518 at 5/23/24 7:08 AM:

[jira] [Comment Edited] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848839#comment-17848839 ] Muralidhar Basani edited comment on KAFKA-16518 at 5/23/24 7:08 AM:

[jira] [Commented] (KAFKA-16518) Storage tool changes for KIP-853

[ https://issues.apache.org/jira/browse/KAFKA-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848839#comment-17848839 ] Muralidhar Basani commented on KAFKA-16518: --- [~jsancio] can I look into this ? > Storage tool

[jira] [Commented] (KAFKA-16814) KRaft broker cannot startup when `partition.metadata` is missing

[ https://issues.apache.org/jira/browse/KAFKA-16814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848599#comment-17848599 ] Muralidhar Basani commented on KAFKA-16814: --- [~showuon] do you think this is in anyway related

[jira] [Assigned] (KAFKA-15258) Consider moving MockAdminClient to the public API

[ https://issues.apache.org/jira/browse/KAFKA-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muralidhar Basani reassigned KAFKA-15258: - Assignee: Muralidhar Basani > Consider moving MockAdminClient to the public

[jira] [Commented] (KAFKA-16802) Move build.gradle java version information inside of a java block

[ https://issues.apache.org/jira/browse/KAFKA-16802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848168#comment-17848168 ] Muralidhar Basani commented on KAFKA-16802: --- [~gharris1727] I can pick this up. > Move

[jira] [Commented] (KAFKA-15258) Consider moving MockAdminClient to the public API

[ https://issues.apache.org/jira/browse/KAFKA-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848158#comment-17848158 ] Muralidhar Basani commented on KAFKA-15258: --- [~mimaison]  I wanted to get your thoughts on

[jira] [Commented] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured

[ https://issues.apache.org/jira/browse/KAFKA-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847989#comment-17847989 ] Muralidhar Basani commented on KAFKA-16790: --- [~christo_lolov] have a pr open.  > Calls to

[jira] [Commented] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured

[ https://issues.apache.org/jira/browse/KAFKA-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847869#comment-17847869 ] Muralidhar Basani commented on KAFKA-16790: --- [~christo_lolov] thank you for the explanation. I

[jira] [Commented] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured

[ https://issues.apache.org/jira/browse/KAFKA-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847584#comment-17847584 ] Muralidhar Basani commented on KAFKA-16790: --- After abit further digging ->

[jira] [Commented] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured

[ https://issues.apache.org/jira/browse/KAFKA-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847392#comment-17847392 ] Muralidhar Basani commented on KAFKA-16790: --- Even though brokerMetadataPublisher is

[jira] [Commented] (KAFKA-16790) Calls to RemoteLogManager are made before it is configured

[ https://issues.apache.org/jira/browse/KAFKA-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847384#comment-17847384 ] Muralidhar Basani commented on KAFKA-16790: --- [~christo_lolov] can I look into this issue ? >

[jira] [Commented] (KAFKA-16333) Removed Deprecated methods KTable#join

[ https://issues.apache.org/jira/browse/KAFKA-16333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847348#comment-17847348 ] Muralidhar Basani commented on KAFKA-16333: --- Agree. thanks. > Removed Deprecated methods

[jira] [Commented] (KAFKA-16448) Add Kafka Streams exception handler for exceptions occuring during processing (KIP-1033)

[ https://issues.apache.org/jira/browse/KAFKA-16448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847294#comment-17847294 ] Muralidhar Basani commented on KAFKA-16448: --- Thanks [~mjsax]  [~lmunoz] if there any sub

[jira] [Commented] (KAFKA-16448) Add Kafka Streams exception handler for exceptions occuring during processing (KIP-1033)

[ https://issues.apache.org/jira/browse/KAFKA-16448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846675#comment-17846675 ] Muralidhar Basani commented on KAFKA-16448: --- [~Dabz] can I try looking into this ? > Add

[jira] [Commented] (KAFKA-16330) Remove Deprecated methods/variables from TaskId

[ https://issues.apache.org/jira/browse/KAFKA-16330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846661#comment-17846661 ] Muralidhar Basani commented on KAFKA-16330: --- I think very soon 4.0.0 might be the upcoming

[jira] [Commented] (KAFKA-16329) Remove Deprecated Task/ThreadMetadata classes and related methods

[ https://issues.apache.org/jira/browse/KAFKA-16329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846660#comment-17846660 ] Muralidhar Basani commented on KAFKA-16329: --- I think very soon 4.0.0 might be the upcoming

[jira] [Commented] (KAFKA-16333) Removed Deprecated methods KTable#join

[ https://issues.apache.org/jira/browse/KAFKA-16333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846658#comment-17846658 ] Muralidhar Basani commented on KAFKA-16333: --- I think very soon 4.0.0 might be the upcoming

[jira] [Commented] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition

[ https://issues.apache.org/jira/browse/KAFKA-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846607#comment-17846607 ] Muralidhar Basani commented on KAFKA-16768: --- To fix this, when Processor#closeAll() is called,

[jira] [Comment Edited] (KAFKA-15258) Consider moving MockAdminClient to the public API

[ https://issues.apache.org/jira/browse/KAFKA-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748858#comment-17748858 ] Muralidhar Basani edited comment on KAFKA-15258 at 7/29/23 9:18 PM:

[jira] [Commented] (KAFKA-15258) Consider moving MockAdminClient to the public API

[ https://issues.apache.org/jira/browse/KAFKA-15258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748858#comment-17748858 ] Muralidhar Basani commented on KAFKA-15258: --- [~mimaison] I can pick this up, if it's confirmed

[jira] [Commented] (KAFKA-14585) Move StorageTool to tools

[ https://issues.apache.org/jira/browse/KAFKA-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703309#comment-17703309 ] Muralidhar Basani commented on KAFKA-14585: --- [~mimaison] I think am done with the changes. I

[jira] [Updated] (KAFKA-14585) Move StorageTool to tools

[ https://issues.apache.org/jira/browse/KAFKA-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muralidhar Basani updated KAFKA-14585: -- Fix Version/s: 3.5.0 > Move StorageTool to tools > - > >

[jira] [Assigned] (KAFKA-14585) Move StorageTool to tools

[ https://issues.apache.org/jira/browse/KAFKA-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muralidhar Basani reassigned KAFKA-14585: - Assignee: Muralidhar Basani > Move StorageTool to tools >

[jira] [Commented] (KAFKA-14585) Move StorageTool to tools

[ https://issues.apache.org/jira/browse/KAFKA-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701874#comment-17701874 ] Muralidhar Basani commented on KAFKA-14585: --- Great, thanks. > Move StorageTool to tools >

[jira] [Commented] (KAFKA-14585) Move StorageTool to tools

[ https://issues.apache.org/jira/browse/KAFKA-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701869#comment-17701869 ] Muralidhar Basani commented on KAFKA-14585: --- Hi [~mimaison] , can I pick this one ? > Move

[jira] [Commented] (KAFKA-14483) Move LocalLog to storage module

[ https://issues.apache.org/jira/browse/KAFKA-14483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701581#comment-17701581 ] Muralidhar Basani commented on KAFKA-14483: --- Hi [~ijuma],  can I pick this up after 14481

[jira] [Commented] (KAFKA-14523) Move RemoteLogManager to the storage module

[ https://issues.apache.org/jira/browse/KAFKA-14523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701393#comment-17701393 ] Muralidhar Basani commented on KAFKA-14523: --- Hi [~satish.duggana] , I see this task is