[jira] [Updated] (KAFKA-15239) producerPerformance system test for old client failed after v3.5.0

[ https://issues.apache.org/jira/browse/KAFKA-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-15239: -- Description: In running producer performance tool in system test for old client, we will try to run

[jira] [Created] (KAFKA-15239) producerPerformance system test for old client failed after v3.5.0

Luke Chen created KAFKA-15239: - Summary: producerPerformance system test for old client failed after v3.5.0 Key: KAFKA-15239 URL: https://issues.apache.org/jira/browse/KAFKA-15239 Project: Kafka

[jira] [Commented] (KAFKA-12283) Flaky Test RebalanceSourceConnectorsIntegrationTest#testMultipleWorkersRejoining

[ https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746199#comment-17746199 ] Luke Chen commented on KAFKA-12283: --- Thanks [~sagarrao] ! > Flaky Test >

[jira] [Resolved] (KAFKA-14712) Confusing error when writing downgraded FeatureImage

[ https://issues.apache.org/jira/browse/KAFKA-14712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14712. --- Resolution: Fixed > Confusing error when writing downgraded FeatureImage >

[jira] [Resolved] (KAFKA-15176) Add missing tests for remote storage metrics

[ https://issues.apache.org/jira/browse/KAFKA-15176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-15176. --- Fix Version/s: 3.6.0 Resolution: Fixed > Add missing tests for remote storage metrics >

[jira] [Created] (KAFKA-15218) NPE will be thrown while deleting topic and fetch from follower concurrently

Luke Chen created KAFKA-15218: - Summary: NPE will be thrown while deleting topic and fetch from follower concurrently Key: KAFKA-15218 URL: https://issues.apache.org/jira/browse/KAFKA-15218 Project:

[jira] [Commented] (KAFKA-14467) Add a test to validate the replica state after processing the OFFSET_MOVED_TO_TIERED_STORAGE error, especially for the transactional state

[ https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744137#comment-17744137 ] Luke Chen commented on KAFKA-14467: --- Sorry, was too busy to work on it. Go ahead to take it over,

[jira] [Updated] (KAFKA-14467) Add a test to validate the replica state after processing the OFFSET_MOVED_TO_TIERED_STORAGE error, especially for the transactional state

[ https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14467: -- Description: [https://github.com/apache/kafka/pull/11390#pullrequestreview-1210993072]  

[jira] [Assigned] (KAFKA-14467) Add a test to validate the replica state after processing the OFFSET_MOVED_TO_TIERED_STORAGE error, especially for the transactional state

[ https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14467: - Assignee: (was: Luke Chen) > Add a test to validate the replica state after processing the

[jira] [Assigned] (KAFKA-15189) Do not initialize RemoteStorage related metrics when disabled at cluster

[ https://issues.apache.org/jira/browse/KAFKA-15189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-15189: - Assignee: Luke Chen > Do not initialize RemoteStorage related metrics when disabled at cluster

[jira] [Assigned] (KAFKA-12261) Splitting partition causes message loss for consumers with auto.offset.reset=latest

[ https://issues.apache.org/jira/browse/KAFKA-12261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-12261: - Fix Version/s: 3.6.0 Assignee: Haruki Okada Resolution: Fixed > Splitting

[jira] [Resolved] (KAFKA-15185) Consumers using the latest strategy may lose data after the topic adds partitions

[ https://issues.apache.org/jira/browse/KAFKA-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-15185. --- Resolution: Duplicate > Consumers using the latest strategy may lose data after the topic adds >

[jira] [Updated] (KAFKA-15166) Add deletePartition API to the RemoteStorageManager

[ https://issues.apache.org/jira/browse/KAFKA-15166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-15166: -- Description: Remote Storage Manager exposes {{deleteLogSegmentData}} API to delete the individual

[jira] [Commented] (KAFKA-14743) MessageConversionsTimeMs for fetch request metric is not updated

[ https://issues.apache.org/jira/browse/KAFKA-14743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742681#comment-17742681 ] Luke Chen commented on KAFKA-14743: --- PR: https://github.com/apache/kafka/pull/13297 >

[jira] [Created] (KAFKA-15176) Add missing tests for remote storage metrics

Luke Chen created KAFKA-15176: - Summary: Add missing tests for remote storage metrics Key: KAFKA-15176 URL: https://issues.apache.org/jira/browse/KAFKA-15176 Project: Kafka Issue Type: Sub-task

[jira] [Assigned] (KAFKA-14581) Move GetOffsetShell to tools

[ https://issues.apache.org/jira/browse/KAFKA-14581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14581: - Assignee: Ruslan Krivoshein > Move GetOffsetShell to tools > > >

[jira] [Commented] (KAFKA-14207) Add a 6.10 section for KRaft

[ https://issues.apache.org/jira/browse/KAFKA-14207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740864#comment-17740864 ] Luke Chen commented on KAFKA-14207: --- Thanks for the info, [~gharris1727] ! > Add a 6.10 section for

[jira] [Commented] (KAFKA-14207) Add a 6.10 section for KRaft

[ https://issues.apache.org/jira/browse/KAFKA-14207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740533#comment-17740533 ] Luke Chen commented on KAFKA-14207: --- [~jagsancio] , in the doc, you mentioned: _For redundancy, a

[jira] [Resolved] (KAFKA-15135) RLM listener configurations passed but ignored by RLMM

[ https://issues.apache.org/jira/browse/KAFKA-15135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-15135. --- Fix Version/s: 3.6.0 Resolution: Fixed > RLM listener configurations passed but ignored by

[jira] [Resolved] (KAFKA-8982) Admin.deleteRecords should retry when failing to fetch metadata

[ https://issues.apache.org/jira/browse/KAFKA-8982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-8982. -- Fix Version/s: 3.6.0 Resolution: Fixed > Admin.deleteRecords should retry when failing to fetch

[jira] [Commented] (KAFKA-15083) Passing "remote.log.metadata.*" configs into RLMM

[ https://issues.apache.org/jira/browse/KAFKA-15083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736073#comment-17736073 ] Luke Chen commented on KAFKA-15083: --- [~satishd] , had a try and I think we still need to pass in the

[jira] [Assigned] (KAFKA-15083) Passing "remote.log.metadata.*" configs into RLMM

[ https://issues.apache.org/jira/browse/KAFKA-15083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-15083: - Assignee: Luke Chen (was: Satish Duggana) > Passing "remote.log.metadata.*" configs into RLMM

[jira] [Commented] (KAFKA-7739) Kafka Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17735221#comment-17735221 ] Luke Chen commented on KAFKA-7739: -- [~jeqo] , please open a JIRA and welcome to contribute on it. Thank

[jira] [Commented] (KAFKA-14953) Add metrics for tiered storage

[ https://issues.apache.org/jira/browse/KAFKA-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17735219#comment-17735219 ] Luke Chen commented on KAFKA-14953: --- [~jeqo] , which PR are you referring to? We haven't got any

[jira] [Resolved] (KAFKA-15066) passing listener name config into TopicBasedRemoteLogMetadataManagerConfig

[ https://issues.apache.org/jira/browse/KAFKA-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-15066. --- Fix Version/s: 3.6.0 Resolution: Fixed > passing listener name config into

[jira] [Resolved] (KAFKA-14709) Move content in connect/mirror/README.md to the docs

[ https://issues.apache.org/jira/browse/KAFKA-14709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14709. --- Fix Version/s: 3.6.0 Resolution: Fixed > Move content in connect/mirror/README.md to the

[jira] [Assigned] (KAFKA-15083) Passing "remote.log.metadata.*" configs into RLMM

[ https://issues.apache.org/jira/browse/KAFKA-15083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-15083: - Assignee: Satish Duggana > Passing "remote.log.metadata.*" configs into RLMM >

[jira] [Created] (KAFKA-15083) Passing "remote.log.metadata.*" configs into RLMM

Luke Chen created KAFKA-15083: - Summary: Passing "remote.log.metadata.*" configs into RLMM Key: KAFKA-15083 URL: https://issues.apache.org/jira/browse/KAFKA-15083 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-15047) Handle rolling segments when the active segment's retention is breached incase of tiered storage is enabled.

[ https://issues.apache.org/jira/browse/KAFKA-15047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731481#comment-17731481 ] Luke Chen commented on KAFKA-15047: --- [~h...@pinterest.com] , the retention implementation PR is under

[jira] [Created] (KAFKA-15066) passing listener name config into TopicBasedRemoteLogMetadataManagerConfig

Luke Chen created KAFKA-15066: - Summary: passing listener name config into TopicBasedRemoteLogMetadataManagerConfig Key: KAFKA-15066 URL: https://issues.apache.org/jira/browse/KAFKA-15066 Project: Kafka

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729618#comment-17729618 ] Luke Chen commented on KAFKA-15046: --- [~ocadaruma] , thanks for the help! Ping me when PR is created.

[jira] [Assigned] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-15046: - Assignee: Haruki Okada > Produce performance issue under high disk load >

[jira] [Comment Edited] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728606#comment-17728606 ] Luke Chen edited comment on KAFKA-15046 at 6/2/23 7:30 AM: --- Currently, the RW

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728606#comment-17728606 ] Luke Chen commented on KAFKA-15046: --- Currently, the RW lock in LeaderEpochFileCache is to protect the

[jira] [Commented] (KAFKA-15046) Produce performance issue under high disk load

[ https://issues.apache.org/jira/browse/KAFKA-15046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728547#comment-17728547 ] Luke Chen commented on KAFKA-15046: --- I agree that io_uring is a good way to fix that, but it needs

[jira] [Updated] (KAFKA-15044) Snappy v.1.1.9.1 NoClassDefFound on ARM machines

[ https://issues.apache.org/jira/browse/KAFKA-15044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-15044: -- Fix Version/s: 3.5.0 > Snappy v.1.1.9.1 NoClassDefFound on ARM machines >

[jira] [Created] (KAFKA-15040) segment copy to remote storage won't work in KRaft mode

Luke Chen created KAFKA-15040: - Summary: segment copy to remote storage won't work in KRaft mode Key: KAFKA-15040 URL: https://issues.apache.org/jira/browse/KAFKA-15040 Project: Kafka Issue

[jira] [Created] (KAFKA-15037) initialize unifiedLog with remoteStorageSystemEnable correctly

Luke Chen created KAFKA-15037: - Summary: initialize unifiedLog with remoteStorageSystemEnable correctly Key: KAFKA-15037 URL: https://issues.apache.org/jira/browse/KAFKA-15037 Project: Kafka

[jira] [Created] (KAFKA-15033) Failed to close repository in stagingRepositories

Luke Chen created KAFKA-15033: - Summary: Failed to close repository in stagingRepositories Key: KAFKA-15033 URL: https://issues.apache.org/jira/browse/KAFKA-15033 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-14953) Add metrics for tiered storage

[ https://issues.apache.org/jira/browse/KAFKA-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726550#comment-17726550 ] Luke Chen commented on KAFKA-14953: --- Sounds good! Thank you! > Add metrics for tiered storage >

[jira] [Commented] (KAFKA-14953) Add metrics for tiered storage

[ https://issues.apache.org/jira/browse/KAFKA-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726121#comment-17726121 ] Luke Chen commented on KAFKA-14953: --- [~abhijeetkumar] , I've expanded the scope of this ticket. Are

[jira] [Updated] (KAFKA-14953) Add metrics for tiered storage

[ https://issues.apache.org/jira/browse/KAFKA-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14953: -- Description: Not just for expired fetch. We also need to add all the metrics described in KIP-405

[jira] [Updated] (KAFKA-14953) Add metrics for tiered storage

[ https://issues.apache.org/jira/browse/KAFKA-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14953: -- Summary: Add metrics for tiered storage (was: Add metrics for expiration of delayed remote fetch) >

[jira] [Updated] (KAFKA-14836) Fix UtilsTest#testToLogDateTimeFormat failure in some cases

[ https://issues.apache.org/jira/browse/KAFKA-14836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14836: -- Fix Version/s: 3.4.1 > Fix UtilsTest#testToLogDateTimeFormat failure in some cases >

[jira] [Resolved] (KAFKA-15015) Binaries contain 2 versions of reload4j

[ https://issues.apache.org/jira/browse/KAFKA-15015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-15015. --- Fix Version/s: 3.5.0 3.4.1 Resolution: Fixed > Binaries contain 2

[jira] [Commented] (KAFKA-15015) Binaries contain 2 versions of reload4j

[ https://issues.apache.org/jira/browse/KAFKA-15015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725226#comment-17725226 ] Luke Chen commented on KAFKA-15015: --- [~atusharm] , yes, you can take it. But since we're going to

[jira] [Commented] (KAFKA-15000) High vulnerability PRISMA-2023-0067 reported in jackson-core

[ https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725159#comment-17725159 ] Luke Chen commented on KAFKA-15000: --- If there's a CVE, it will give us more info about it. In this

[jira] [Comment Edited] (KAFKA-15000) High vulnerability PRISMA-2023-0067 reported in jackson-core

[ https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723867#comment-17723867 ] Luke Chen edited comment on KAFKA-15000 at 5/18/23 9:20 AM: [~arushir] ,

[jira] [Commented] (KAFKA-15000) High vulnerability PRISMA-2023-0067 reported in jackson-core

[ https://issues.apache.org/jira/browse/KAFKA-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723867#comment-17723867 ] Luke Chen commented on KAFKA-15000: --- [~arushir] , where do you see this is a "high vulnerability"?

[jira] [Commented] (KAFKA-14692) Issues in Zookeeper to KRaft migration docs

[ https://issues.apache.org/jira/browse/KAFKA-14692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723090#comment-17723090 ] Luke Chen commented on KAFKA-14692: --- Remove this from 3.4.1. > Issues in Zookeeper to KRaft migration

[jira] [Updated] (KAFKA-14692) Issues in Zookeeper to KRaft migration docs

[ https://issues.apache.org/jira/browse/KAFKA-14692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14692: -- Fix Version/s: (was: 3.4.1) > Issues in Zookeeper to KRaft migration docs >

[jira] [Resolved] (KAFKA-14983) Upgrade jetty-server to 9.4.51

[ https://issues.apache.org/jira/browse/KAFKA-14983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14983. --- Resolution: Fixed > Upgrade jetty-server to 9.4.51 > -- > >

[jira] [Commented] (KAFKA-7739) Kafka Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722129#comment-17722129 ] Luke Chen commented on KAFKA-7739: -- Good catch! Thanks all! > Kafka Tiered Storage >

[jira] [Updated] (KAFKA-14983) Upgrade jetty-server to 9.4.51

[ https://issues.apache.org/jira/browse/KAFKA-14983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14983: -- Fix Version/s: 3.4.1 > Upgrade jetty-server to 9.4.51 > -- > >

[jira] [Updated] (KAFKA-14982) Improve the kafka-metadata-quorum output

[ https://issues.apache.org/jira/browse/KAFKA-14982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14982: -- Labels: need-kip (was: ) > Improve the kafka-metadata-quorum output >

[jira] [Updated] (KAFKA-14982) Improve the kafka-metadata-quorum output

[ https://issues.apache.org/jira/browse/KAFKA-14982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14982: -- Affects Version/s: 3.5.0 > Improve the kafka-metadata-quorum output >

[jira] [Created] (KAFKA-14982) Improve the kafka-metadata-quorum output

Luke Chen created KAFKA-14982: - Summary: Improve the kafka-metadata-quorum output Key: KAFKA-14982 URL: https://issues.apache.org/jira/browse/KAFKA-14982 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-14256) Update to Scala 2.13.10

[ https://issues.apache.org/jira/browse/KAFKA-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14256: -- Summary: Update to Scala 2.13.10 (was: Update to Scala 2.13.9) > Update to Scala 2.13.10 >

[jira] [Updated] (KAFKA-14256) Update to Scala 2.13.10

[ https://issues.apache.org/jira/browse/KAFKA-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14256: -- Fix Version/s: 3.4.0 > Update to Scala 2.13.10 > --- > > Key:

[jira] [Resolved] (KAFKA-14662) ACL listings in documentation are out of date

[ https://issues.apache.org/jira/browse/KAFKA-14662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14662. --- Fix Version/s: 3.6.0 Resolution: Fixed > ACL listings in documentation are out of date >

[jira] [Resolved] (KAFKA-14963) Incorrect partition count metrics for kraft controllers

[ https://issues.apache.org/jira/browse/KAFKA-14963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14963. --- Resolution: Fixed > Incorrect partition count metrics for kraft controllers >

[jira] [Updated] (KAFKA-14805) KRaft Controller shouldn't allow metadata updates before migration starts

[ https://issues.apache.org/jira/browse/KAFKA-14805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14805: -- Fix Version/s: (was: 3.4.1) > KRaft Controller shouldn't allow metadata updates before migration

[jira] [Commented] (KAFKA-14914) binarySearch in AbstactIndex may execute with infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-14914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719585#comment-17719585 ] Luke Chen commented on KAFKA-14914: --- [~flashmouse] , thanks for reporting this issue. Does the offset

[jira] [Comment Edited] (KAFKA-14817) LogCleaner mark some partitions of __consumer_offsets as uncleanable

[ https://issues.apache.org/jira/browse/KAFKA-14817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719250#comment-17719250 ] Luke Chen edited comment on KAFKA-14817 at 5/4/23 10:11 AM:

[jira] [Commented] (KAFKA-14817) LogCleaner mark some partitions of __consumer_offsets as uncleanable

[ https://issues.apache.org/jira/browse/KAFKA-14817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719250#comment-17719250 ] Luke Chen commented on KAFKA-14817: --- [~polaris.alioth] [~mrMigles] , thanks for reporting this issue.

[jira] [Updated] (KAFKA-14644) Process should stop after failure in raft IO thread

[ https://issues.apache.org/jira/browse/KAFKA-14644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14644: -- Fix Version/s: 3.4.1 > Process should stop after failure in raft IO thread >

[jira] [Updated] (KAFKA-14946) KRaft controller node shutting down while renouncing leadership

[ https://issues.apache.org/jira/browse/KAFKA-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14946: -- Fix Version/s: 3.4.1 > KRaft controller node shutting down while renouncing leadership >

[jira] [Updated] (KAFKA-14946) KRaft controller node shutting down while renouncing leadership

[ https://issues.apache.org/jira/browse/KAFKA-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14946: -- Fix Version/s: 3.5.0 > KRaft controller node shutting down while renouncing leadership >

[jira] [Updated] (KAFKA-14909) KRaft Controllers not setting ZkMigrationReady tagged field

[ https://issues.apache.org/jira/browse/KAFKA-14909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14909: -- Fix Version/s: (was: 3.4.1) > KRaft Controllers not setting ZkMigrationReady tagged field >

[jira] [Updated] (KAFKA-14946) KRaft controller node shutting down while renouncing leadership

[ https://issues.apache.org/jira/browse/KAFKA-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14946: -- Summary: KRaft controller node shutting down while renouncing leadership (was: KRaft Node Shutting

[jira] [Updated] (KAFKA-14946) KRaft Node Shutting down while renouncing leadership

[ https://issues.apache.org/jira/browse/KAFKA-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14946: -- Summary: KRaft Node Shutting down while renouncing leadership (was: KRaft Node Shutting down while )

[jira] [Updated] (KAFKA-14946) KRaft Node Shutting down while

[ https://issues.apache.org/jira/browse/KAFKA-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14946: -- Summary: KRaft Node Shutting down while (was: Kafka Node Shutting Down Automatically) > KRaft Node

[jira] [Assigned] (KAFKA-14946) Kafka Node Shutting Down Automatically

[ https://issues.apache.org/jira/browse/KAFKA-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14946: - Assignee: Luke Chen > Kafka Node Shutting Down Automatically >

[jira] [Resolved] (KAFKA-14944) Reduce CompletedFetch#parseRecord() memory copy

[ https://issues.apache.org/jira/browse/KAFKA-14944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14944. --- Fix Version/s: 3.6.0 Resolution: Fixed > Reduce CompletedFetch#parseRecord() memory copy >

[jira] [Updated] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying

[ https://issues.apache.org/jira/browse/KAFKA-14945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14945: -- Fix Version/s: (was: 3.6.0) > Add Serializer#serializeToByteBuffer() to reduce memory copying >

[jira] [Reopened] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying

[ https://issues.apache.org/jira/browse/KAFKA-14945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reopened KAFKA-14945: --- > Add Serializer#serializeToByteBuffer() to reduce memory copying >

[jira] [Resolved] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying

[ https://issues.apache.org/jira/browse/KAFKA-14945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14945. --- Fix Version/s: 3.6.0 Resolution: Fixed > Add Serializer#serializeToByteBuffer() to reduce

[jira] [Assigned] (KAFKA-14909) KRaft Controllers not setting ZkMigrationReady tagged field

[ https://issues.apache.org/jira/browse/KAFKA-14909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14909: - Assignee: Luke Chen > KRaft Controllers not setting ZkMigrationReady tagged field >

[jira] [Resolved] (KAFKA-14908) Sporadic "Address already in use" when starting kafka cluster embedded within tests

[ https://issues.apache.org/jira/browse/KAFKA-14908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14908. --- Fix Version/s: 3.6.0 Resolution: Fixed > Sporadic "Address already in use" when starting

[jira] [Resolved] (KAFKA-14883) Broker state should be "observer" in KRaft quorum

[ https://issues.apache.org/jira/browse/KAFKA-14883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14883. --- Fix Version/s: 3.5.0 Resolution: Fixed > Broker state should be "observer" in KRaft quorum >

[jira] [Resolved] (KAFKA-9550) RemoteLogManager - copying eligible log segments to remote storage implementation

[ https://issues.apache.org/jira/browse/KAFKA-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-9550. -- Resolution: Fixed > RemoteLogManager - copying eligible log segments to remote storage >

[jira] [Resolved] (KAFKA-14889) RemoteLogManager - allow consumer fetch records from remote storage implementation

[ https://issues.apache.org/jira/browse/KAFKA-14889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14889. --- Resolution: Duplicate > RemoteLogManager - allow consumer fetch records from remote storage >

[jira] [Created] (KAFKA-14889) RemoteLogManager - allow consumer fetch records from remote storage implementation

Luke Chen created KAFKA-14889: - Summary: RemoteLogManager - allow consumer fetch records from remote storage implementation Key: KAFKA-14889 URL: https://issues.apache.org/jira/browse/KAFKA-14889

[jira] [Assigned] (KAFKA-14888) RemoteLogManager - deleting expired/size breached log segments to remote storage implementation

[ https://issues.apache.org/jira/browse/KAFKA-14888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14888: - Assignee: Luke Chen > RemoteLogManager - deleting expired/size breached log segments to remote

[jira] [Assigned] (KAFKA-14889) RemoteLogManager - allow consumer fetch records from remote storage implementation

[ https://issues.apache.org/jira/browse/KAFKA-14889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14889: - Assignee: Satish Duggana > RemoteLogManager - allow consumer fetch records from remote storage

[jira] [Created] (KAFKA-14888) RemoteLogManager - deleting expired/size breached log segments to remote storage implementation

Luke Chen created KAFKA-14888: - Summary: RemoteLogManager - deleting expired/size breached log segments to remote storage implementation Key: KAFKA-14888 URL: https://issues.apache.org/jira/browse/KAFKA-14888

[jira] [Created] (KAFKA-14877) refactor

Luke Chen created KAFKA-14877: - Summary: refactor Key: KAFKA-14877 URL: https://issues.apache.org/jira/browse/KAFKA-14877 Project: Kafka Issue Type: Sub-task Reporter: Luke Chen

[jira] [Updated] (KAFKA-14877) refactor InMemoryLeaderEpochCheckpoint

[ https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14877: -- Summary: refactor InMemoryLeaderEpochCheckpoint (was: refactor ) > refactor

[jira] [Commented] (KAFKA-7739) Kafka Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706237#comment-17706237 ] Luke Chen commented on KAFKA-7739: -- [~twmb] , we already use -4 to indicate the earliest log start

[jira] [Created] (KAFKA-14850) Introduce InMemoryLeaderEpochCheckpoint to allow quick write/read

Luke Chen created KAFKA-14850: - Summary: Introduce InMemoryLeaderEpochCheckpoint to allow quick write/read Key: KAFKA-14850 URL: https://issues.apache.org/jira/browse/KAFKA-14850 Project: Kafka

[jira] [Commented] (KAFKA-14016) Revoke more partitions than expected in Cooperative rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703825#comment-17703825 ] Luke Chen commented on KAFKA-14016: --- It's been a while that I cannot remember it clearly. But it looks

[jira] [Assigned] (KAFKA-14206) Upgrade zookeeper to 3.7.1 to address security vulnerabilities

[ https://issues.apache.org/jira/browse/KAFKA-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-14206: - Assignee: (was: Luke Chen) > Upgrade zookeeper to 3.7.1 to address security

[jira] [Commented] (KAFKA-14218) replace temp file handler with JUnit 5 Temporary Directory Support

[ https://issues.apache.org/jira/browse/KAFKA-14218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697705#comment-17697705 ] Luke Chen commented on KAFKA-14218: --- No need to raise a KIP. You can start with some tests to see if

[jira] [Commented] (KAFKA-14768) proposal to reduce the first message's send time cost and max block time for safety

[ https://issues.apache.org/jira/browse/KAFKA-14768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695451#comment-17695451 ] Luke Chen commented on KAFKA-14768: --- For (1), could you explain what "warmup" messages mean? How could

[jira] [Commented] (KAFKA-14771) Include current thread ids in ConcurrentModificationException message

[ https://issues.apache.org/jira/browse/KAFKA-14771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695434#comment-17695434 ] Luke Chen commented on KAFKA-14771: --- [~pierDipi] , the suggestion makes sense to me. Welcome to submit

[jira] [Resolved] (KAFKA-14729) The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

[ https://issues.apache.org/jira/browse/KAFKA-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14729. --- Fix Version/s: 3.5.0 Resolution: Fixed > The kafakConsumer pollForFetches(timer) method

[jira] [Resolved] (KAFKA-14371) quorum-state file contains empty/unused clusterId field

[ https://issues.apache.org/jira/browse/KAFKA-14371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-14371. --- Fix Version/s: 3.5.0 Resolution: Fixed > quorum-state file contains empty/unused clusterId

[jira] [Updated] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-13771: -- Fix Version/s: 3.5.0 > Support to explicitly delete delegationTokens that have expired but have not

[jira] [Commented] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694387#comment-17694387 ] Luke Chen commented on KAFKA-13771: --- [~RivenSun] , you can update it by yourselves. Thanks. > Support

[jira] [Updated] (KAFKA-14295) FetchMessageConversionsPerSec meter not recorded

[ https://issues.apache.org/jira/browse/KAFKA-14295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-14295: -- Fix Version/s: 3.4.1 > FetchMessageConversionsPerSec meter not recorded >

<    1   2   3   4   5   6   7   8   9   10   >