[jira] [Comment Edited] (KAFKA-16976) Improve the dynamic config handling for RemoteLogManagerConfig when a broker is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-16976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856131#comment-17856131 ] Kamal Chandraprakash edited comment on KAFKA-16976 at 6/19/24 5:48 AM:

[jira] [Commented] (KAFKA-16976) Improve the dynamic config handling for RemoteLogManagerConfig when a broker is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-16976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856131#comment-17856131 ] Kamal Chandraprakash commented on KAFKA-16976: -- [~chiacyu]  Thanks for showing interest to

[jira] [Assigned] (KAFKA-16976) Improve the dynamic config handling for RemoteLogManagerConfig when a broker is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-16976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-16976: Assignee: Kamal Chandraprakash > Improve the dynamic config handling for

[jira] [Updated] (KAFKA-16948) Reset tier lag metrics on becoming follower

[ https://issues.apache.org/jira/browse/KAFKA-16948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16948: - Issue Type: Bug (was: Task) > Reset tier lag metrics on becoming follower >

[jira] [Assigned] (KAFKA-16976) Improve the dynamic config handling for RemoteLogManagerConfig when a broker is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-16976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-16976: Assignee: (was: Kamal Chandraprakash) > Improve the dynamic config

[jira] [Updated] (KAFKA-16780) Txn consumer exerts pressure on remote storage when collecting aborted transactions

[ https://issues.apache.org/jira/browse/KAFKA-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16780: - Summary: Txn consumer exerts pressure on remote storage when collecting aborted

[jira] [Updated] (KAFKA-16780) Txn consumer exerts pressure on remote storage when collecting aborted transaction

[ https://issues.apache.org/jira/browse/KAFKA-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16780: - Summary: Txn consumer exerts pressure on remote storage when collecting aborted

[jira] [Updated] (KAFKA-16780) Txn consumer exerts pressure on remote storage when reading non-txn topic

[ https://issues.apache.org/jira/browse/KAFKA-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16780: - Labels: kip (was: ) > Txn consumer exerts pressure on remote storage when

[jira] [Assigned] (KAFKA-16780) Txn consumer exerts pressure on remote storage when reading non-txn topic

[ https://issues.apache.org/jira/browse/KAFKA-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-16780: Assignee: Kamal Chandraprakash > Txn consumer exerts pressure on remote

[jira] [Resolved] (KAFKA-15420) Kafka Tiered Storage V1

[ https://issues.apache.org/jira/browse/KAFKA-15420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-15420. -- Resolution: Fixed > Kafka Tiered Storage V1 > --- > >

[jira] [Reopened] (KAFKA-15420) Kafka Tiered Storage V1

[ https://issues.apache.org/jira/browse/KAFKA-15420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reopened KAFKA-15420: -- > Kafka Tiered Storage V1 > --- > > Key:

[jira] [Created] (KAFKA-16948) Reset tier lag metrics on becoming follower

Kamal Chandraprakash created KAFKA-16948: Summary: Reset tier lag metrics on becoming follower Key: KAFKA-16948 URL: https://issues.apache.org/jira/browse/KAFKA-16948 Project: Kafka

[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 ] Kamal Chandraprakash updated KAFKA-15166: - Fix Version/s: (was: 3.8.0) > Add deletePartition API to the

[jira] [Resolved] (KAFKA-15777) Configurable remote fetch bytes per partition from Consumer

[ https://issues.apache.org/jira/browse/KAFKA-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-15777. -- Resolution: Won't Fix > Configurable remote fetch bytes per partition from

[jira] [Commented] (KAFKA-16885) Consider renaming RemoteLogManagerConfig#enableRemoteStorageSystem to RemoteLogManagerConfig#isRemoteStorageSystemEnabled

[ https://issues.apache.org/jira/browse/KAFKA-16885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853492#comment-17853492 ] Kamal Chandraprakash commented on KAFKA-16885: -- [~chiacyu]  Are you working on this? >

[jira] [Assigned] (KAFKA-16890) Failing to build aux state on broker failover

[ https://issues.apache.org/jira/browse/KAFKA-16890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-16890: Assignee: Kamal Chandraprakash > Failing to build aux state on broker

[jira] [Created] (KAFKA-16904) Metric to measure the latency of remote read requests

Kamal Chandraprakash created KAFKA-16904: Summary: Metric to measure the latency of remote read requests Key: KAFKA-16904 URL: https://issues.apache.org/jira/browse/KAFKA-16904 Project: Kafka

[jira] [Commented] (KAFKA-16882) Migrate RemoteLogSegmentLifecycleTest to new test infra

[ https://issues.apache.org/jira/browse/KAFKA-16882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17851742#comment-17851742 ] Kamal Chandraprakash commented on KAFKA-16882: -- yes, this is a duplicate. didn't looked at

[jira] [Created] (KAFKA-16882) Migrate RemoteLogSegmentLifecycleTest to new test infra

Kamal Chandraprakash created KAFKA-16882: Summary: Migrate RemoteLogSegmentLifecycleTest to new test infra Key: KAFKA-16882 URL: https://issues.apache.org/jira/browse/KAFKA-16882 Project:

[jira] [Assigned] (KAFKA-16882) Migrate RemoteLogSegmentLifecycleTest to new test infra

[ https://issues.apache.org/jira/browse/KAFKA-16882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-16882: Assignee: Kamal Chandraprakash (was: Kuan Po Tseng) > Migrate

[jira] [Updated] (KAFKA-16882) Migrate RemoteLogSegmentLifecycleTest to new test infra

[ https://issues.apache.org/jira/browse/KAFKA-16882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16882: - Fix Version/s: (was: 3.9.0) > Migrate RemoteLogSegmentLifecycleTest to new

[jira] [Updated] (KAFKA-15776) Update delay timeout for DelayedRemoteFetch request

[ https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15776: - Fix Version/s: 3.8.0 > Update delay timeout for DelayedRemoteFetch request >

[jira] [Commented] (KAFKA-16780) Txn consumer exerts pressure on remote storage when reading non-txn topic

[ https://issues.apache.org/jira/browse/KAFKA-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849695#comment-17849695 ] Kamal Chandraprakash commented on KAFKA-16780: -- The issue mentioned above also applies to

[jira] [Comment Edited] (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=17847876#comment-17847876 ] Kamal Chandraprakash edited comment on KAFKA-16414 at 5/20/24 1:14 PM:

[jira] [Comment Edited] (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=17847876#comment-17847876 ] Kamal Chandraprakash edited comment on KAFKA-16414 at 5/20/24 1:14 PM:

[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=17847876#comment-17847876 ] Kamal Chandraprakash commented on KAFKA-16414: -- We may need a discussion before changing

[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=17847873#comment-17847873 ] Kamal Chandraprakash commented on KAFKA-16385: -- Adding the comment for posterity: > OK,

[jira] [Updated] (KAFKA-16780) Txn consumer exerts pressure on remote storage when reading non-txn topic

[ https://issues.apache.org/jira/browse/KAFKA-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16780: - Description: h3. Logic to read aborted txns: # When the consumer enables

[jira] [Updated] (KAFKA-16780) Txn consumer exerts pressure on remote storage when reading non-txn topic

[ https://issues.apache.org/jira/browse/KAFKA-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16780: - Description: h3. Logic to read aborted txns: # When the consumer enables

[jira] [Updated] (KAFKA-16780) Txn consumer exerts pressure on remote storage when reading non-txn topic

[ https://issues.apache.org/jira/browse/KAFKA-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16780: - Description: h3. Logic to read aborted txns: # When the consumer enables

[jira] [Created] (KAFKA-16780) Txn consumer exerts pressure on remote storage when reading non-txn topic

Kamal Chandraprakash created KAFKA-16780: Summary: Txn consumer exerts pressure on remote storage when reading non-txn topic Key: KAFKA-16780 URL: https://issues.apache.org/jira/browse/KAFKA-16780

[jira] [Updated] (KAFKA-16696) Remove the in-memory implementation of RSM and RLMM

[ https://issues.apache.org/jira/browse/KAFKA-16696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16696: - Description: The in-memory implementation of RSM and RLMM were written to write

[jira] [Updated] (KAFKA-16696) Remove the in-memory implementation of RSM and RLMM

[ https://issues.apache.org/jira/browse/KAFKA-16696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16696: - Description: The in-memory implementation of RSM and RLMM were written to write

[jira] [Created] (KAFKA-16696) Remove the in-memory implementation of RSM and RLMM

Kamal Chandraprakash created KAFKA-16696: Summary: Remove the in-memory implementation of RSM and RLMM Key: KAFKA-16696 URL: https://issues.apache.org/jira/browse/KAFKA-16696 Project: Kafka

[jira] [Commented] (KAFKA-16511) Leaking tiered segments

[ https://issues.apache.org/jira/browse/KAFKA-16511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17843185#comment-17843185 ] Kamal Chandraprakash commented on KAFKA-16511: -- [~showuon]  Your analysis is correct. I

[jira] [Updated] (KAFKA-16605) Fix the flaky LogCleanerParameterizedIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16605: - Description:

[jira] [Created] (KAFKA-16605) Fix the flaky LogCleanerParameterizedIntegrationTest

Kamal Chandraprakash created KAFKA-16605: Summary: Fix the flaky LogCleanerParameterizedIntegrationTest Key: KAFKA-16605 URL: https://issues.apache.org/jira/browse/KAFKA-16605 Project: Kafka

[jira] [Updated] (KAFKA-15480) Add RemoteStorageInterruptedException

[ https://issues.apache.org/jira/browse/KAFKA-15480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15480: - Labels: kip (was: ) > Add RemoteStorageInterruptedException >

[jira] [Updated] (KAFKA-15776) Update delay timeout for DelayedRemoteFetch request

[ https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15776: - Labels: kip (was: ) > Update delay timeout for DelayedRemoteFetch request >

[jira] [Updated] (KAFKA-15776) Update delay timeout for DelayedRemoteFetch request

[ https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15776: - Labels: kip-1018 (was: kip) > Update delay timeout for DelayedRemoteFetch

[jira] [Assigned] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-15341: Assignee: Kamal Chandraprakash > Enabling TS for a topic during rolling

[jira] [Assigned] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems

[ https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-15341: Assignee: (was: Kamal Chandraprakash) > Enabling TS for a topic

[jira] [Assigned] (KAFKA-15682) Ensure internal remote log metadata topic does not expire its segments before deleting user-topic segments

[ https://issues.apache.org/jira/browse/KAFKA-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-15682: Assignee: Kamal Chandraprakash > Ensure internal remote log metadata

[jira] [Assigned] (KAFKA-15682) Ensure internal remote log metadata topic does not expire its segments before deleting user-topic segments

[ https://issues.apache.org/jira/browse/KAFKA-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-15682: Assignee: (was: Kamal Chandraprakash) > Ensure internal remote log

[jira] [Assigned] (KAFKA-9578) Kafka Tiered Storage - System Tests

[ https://issues.apache.org/jira/browse/KAFKA-9578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-9578: --- Assignee: (was: Kamal Chandraprakash) > Kafka Tiered Storage - System

[jira] [Assigned] (KAFKA-13560) Load indexes and data in async manner in the critical path of replica fetcher threads.

[ https://issues.apache.org/jira/browse/KAFKA-13560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-13560: Assignee: (was: Kamal Chandraprakash) > Load indexes and data in

[jira] [Assigned] (KAFKA-16511) Leaking tiered segments

[ https://issues.apache.org/jira/browse/KAFKA-16511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-16511: Assignee: Kamal Chandraprakash > Leaking tiered segments >

[jira] [Assigned] (KAFKA-14915) Option to consume multiple partitions that have their data in remote storage for the target offsets.

[ https://issues.apache.org/jira/browse/KAFKA-14915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-14915: Assignee: (was: Kamal Chandraprakash) > Option to consume multiple

[jira] [Updated] (KAFKA-16511) Leaking tiered segments

[ https://issues.apache.org/jira/browse/KAFKA-16511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16511: - Description: I have some topics there were not written since a few days (having

[jira] [Commented] (KAFKA-16511) Leaking tiered segments

[ https://issues.apache.org/jira/browse/KAFKA-16511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836762#comment-17836762 ] Kamal Chandraprakash commented on KAFKA-16511: -- [~fvisconte]  The issue might be due to the

[jira] [Commented] (KAFKA-16511) Leaking tiered segments

[ https://issues.apache.org/jira/browse/KAFKA-16511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836444#comment-17836444 ] Kamal Chandraprakash commented on KAFKA-16511: -- The segment deletion might be stuck due to

[jira] [Commented] (KAFKA-16511) Leaking tiered segments

[ https://issues.apache.org/jira/browse/KAFKA-16511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836289#comment-17836289 ] Kamal Chandraprakash commented on KAFKA-16511: -- Can you also paste the contents of

[jira] [Commented] (KAFKA-16511) Leaking tiered segments

[ https://issues.apache.org/jira/browse/KAFKA-16511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836277#comment-17836277 ] Kamal Chandraprakash commented on KAFKA-16511: -- [~fvisconte] > We can see that despite the

[jira] (KAFKA-16511) Leaking tiered segments

[ https://issues.apache.org/jira/browse/KAFKA-16511 ] Kamal Chandraprakash deleted comment on KAFKA-16511: -- was (Author: ckamal): [~fvisconte]  >From logs, the issue is on partition-765 and segment >`02971163.log` . There

[jira] [Commented] (KAFKA-16511) Leaking tiered segments

[ https://issues.apache.org/jira/browse/KAFKA-16511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836276#comment-17836276 ] Kamal Chandraprakash commented on KAFKA-16511: -- [~fvisconte]  >From logs, the issue is on

[jira] [Resolved] (KAFKA-16456) Can't stop kafka debug logs

[ https://issues.apache.org/jira/browse/KAFKA-16456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-16456. -- Resolution: Not A Problem You can also dynamically change the broker loggers

[jira] [Updated] (KAFKA-16454) Snapshot the state of remote log metadata for all the partitions

[ https://issues.apache.org/jira/browse/KAFKA-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16454: - Description: When restarting the broker, we are reading from the beginning of

[jira] [Created] (KAFKA-16454) Snapshot the state of remote log metadata for all the partitions

Kamal Chandraprakash created KAFKA-16454: Summary: Snapshot the state of remote log metadata for all the partitions Key: KAFKA-16454 URL: https://issues.apache.org/jira/browse/KAFKA-16454

[jira] [Created] (KAFKA-16452) Bound highwatermark offset to range b/w local-log-start-offset and log-end-offset

Kamal Chandraprakash created KAFKA-16452: Summary: Bound highwatermark offset to range b/w local-log-start-offset and log-end-offset Key: KAFKA-16452 URL: https://issues.apache.org/jira/browse/KAFKA-16452

[jira] [Comment Edited] (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=17832561#comment-17832561 ] Kamal Chandraprakash edited comment on KAFKA-16414 at 3/31/24 9:25 AM:

[jira] [Comment Edited] (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=17832561#comment-17832561 ] Kamal Chandraprakash edited comment on KAFKA-16414 at 3/31/24 9:25 AM:

[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=17832561#comment-17832561 ] Kamal Chandraprakash commented on KAFKA-16414: -- My suggestion is to keep the existing

[jira] [Commented] (KAFKA-16161) Avoid creating remote log metadata snapshot file in partition data directory.

[ https://issues.apache.org/jira/browse/KAFKA-16161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831619#comment-17831619 ] Kamal Chandraprakash commented on KAFKA-16161: -- Not yet started. Will work on this task by

[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=17831161#comment-17831161 ] Kamal Chandraprakash commented on KAFKA-16414: -- I noticed the behavior change of

[jira] [Assigned] (KAFKA-15206) Flaky test RemoteIndexCacheTest.testClose()

[ https://issues.apache.org/jira/browse/KAFKA-15206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-15206: Assignee: Kamal Chandraprakash (was: Lan Ding) > Flaky test

[jira] [Commented] (KAFKA-15776) Update delay timeout for DelayedRemoteFetch request

[ https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812155#comment-17812155 ] Kamal Chandraprakash commented on KAFKA-15776: -- I've opened a KIP to add new

[jira] [Commented] (KAFKA-15776) Update delay timeout for DelayedRemoteFetch request

[ https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809117#comment-17809117 ] Kamal Chandraprakash commented on KAFKA-15776: -- > I think having to configure a very high

[jira] [Commented] (KAFKA-15776) Update delay timeout for DelayedRemoteFetch request

[ https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809116#comment-17809116 ] Kamal Chandraprakash commented on KAFKA-15776: -- [~fvisconte]  We are cancelling the

[jira] [Commented] (KAFKA-16105) Reassignment of tiered topics is failing due to RemoteStorageException

[ https://issues.apache.org/jira/browse/KAFKA-16105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807397#comment-17807397 ] Kamal Chandraprakash commented on KAFKA-16105: -- [~anatolypopov]  Could you write an

[jira] [Updated] (KAFKA-16146) Checkpoint log-start-offset for remote log enabled topics

[ https://issues.apache.org/jira/browse/KAFKA-16146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16146: - Description: The log-start-offset is not getting flushed to the checkpoint due

[jira] [Updated] (KAFKA-16146) Checkpoint log-start-offset for remote log enabled topics

[ https://issues.apache.org/jira/browse/KAFKA-16146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-16146: - Summary: Checkpoint log-start-offset for remote log enabled topics (was:

[jira] [Created] (KAFKA-16146) Checkpoint log-start-offset after remote log deletion

Kamal Chandraprakash created KAFKA-16146: Summary: Checkpoint log-start-offset after remote log deletion Key: KAFKA-16146 URL: https://issues.apache.org/jira/browse/KAFKA-16146 Project: Kafka

[jira] [Commented] (KAFKA-16088) Not reading active segments when RemoteFetch return Empty Records.

[ https://issues.apache.org/jira/browse/KAFKA-16088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803941#comment-17803941 ] Kamal Chandraprakash commented on KAFKA-16088: -- [~goyarpit]  Could you please write a

[jira] [Commented] (KAFKA-16073) Kafka Tiered Storage Bug: Consumer Fetch Error Due to Delayed localLogStartOffset Update During Segment Deletion

[ https://issues.apache.org/jira/browse/KAFKA-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803940#comment-17803940 ] Kamal Chandraprakash commented on KAFKA-16073: -- [~hzh0425@apache]  The approach LGTM.

[jira] [Commented] (KAFKA-15682) Ensure internal remote log metadata topic does not expire its segments before deleting user-topic segments

[ https://issues.apache.org/jira/browse/KAFKA-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803939#comment-17803939 ] Kamal Chandraprakash commented on KAFKA-15682: -- The retention of `__remote_log_metadata` is

[jira] [Updated] (KAFKA-15876) Introduce Remote Storage Not Ready Exception

[ https://issues.apache.org/jira/browse/KAFKA-15876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15876: - Fix Version/s: 3.8.0 > Introduce Remote Storage Not Ready Exception >

[jira] [Commented] (KAFKA-16073) Kafka Tiered Storage Bug: Consumer Fetch Error Due to Delayed localLogStartOffset Update During Segment Deletion

[ https://issues.apache.org/jira/browse/KAFKA-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17803486#comment-17803486 ] Kamal Chandraprakash commented on KAFKA-16073: -- [~hzh0425@apache]  Are you working on this

[jira] [Commented] (KAFKA-15777) Configurable remote fetch bytes per partition from Consumer

[ https://issues.apache.org/jira/browse/KAFKA-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801817#comment-17801817 ] Kamal Chandraprakash commented on KAFKA-15777: -- [~isding_l]  This task require a KIP as we

[jira] [Updated] (KAFKA-15777) Configurable remote fetch bytes per partition from Consumer

[ https://issues.apache.org/jira/browse/KAFKA-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15777: - Labels: kip (was: ) > Configurable remote fetch bytes per partition from

[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 ] Kamal Chandraprakash updated KAFKA-15166: - Labels: kip (was: ) > Add deletePartition API to the RemoteStorageManager >

[jira] [Commented] (KAFKA-15931) Cached transaction index gets closed if tiered storage read is interrupted

[ https://issues.apache.org/jira/browse/KAFKA-15931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791140#comment-17791140 ] Kamal Chandraprakash commented on KAFKA-15931: -- [~ivanyu]  Thanks for filing this issue!

[jira] [Updated] (KAFKA-15876) Introduce Remote Storage Not Ready Exception

[ https://issues.apache.org/jira/browse/KAFKA-15876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15876: - Labels: kip (was: ) > Introduce Remote Storage Not Ready Exception >

[jira] [Created] (KAFKA-15876) Introduce Remote Storage Not Ready Exception

Kamal Chandraprakash created KAFKA-15876: Summary: Introduce Remote Storage Not Ready Exception Key: KAFKA-15876 URL: https://issues.apache.org/jira/browse/KAFKA-15876 Project: Kafka

[jira] [Created] (KAFKA-15859) Introduce delayed remote list offsets to make LIST_OFFSETS async

Kamal Chandraprakash created KAFKA-15859: Summary: Introduce delayed remote list offsets to make LIST_OFFSETS async Key: KAFKA-15859 URL: https://issues.apache.org/jira/browse/KAFKA-15859

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

[ https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-14877: Assignee: (was: Kamal Chandraprakash) > refactor

[jira] [Comment Edited] (KAFKA-14877) refactor InMemoryLeaderEpochCheckpoint

[ https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786768#comment-17786768 ] Kamal Chandraprakash edited comment on KAFKA-14877 at 11/16/23 2:20 PM:

[jira] [Comment Edited] (KAFKA-14877) refactor InMemoryLeaderEpochCheckpoint

[ https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786768#comment-17786768 ] Kamal Chandraprakash edited comment on KAFKA-14877 at 11/16/23 2:20 PM:

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

[ https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786768#comment-17786768 ] Kamal Chandraprakash commented on KAFKA-14877: -- [~showuon] [~divijvaidya]  The expectation

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

[ https://issues.apache.org/jira/browse/KAFKA-14877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-14877: Assignee: Kamal Chandraprakash > refactor InMemoryLeaderEpochCheckpoint

[jira] [Updated] (KAFKA-15776) Update delay timeout for DelayedRemoteFetch request

[ https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15776: - Summary: Update delay timeout for DelayedRemoteFetch request (was:

[jira] [Comment Edited] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785956#comment-17785956 ] Kamal Chandraprakash edited comment on KAFKA-15376 at 11/14/23 4:29 PM:

[jira] [Commented] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785962#comment-17785962 ] Kamal Chandraprakash commented on KAFKA-15376: -- With unclean-leader-election enabled, there

[jira] [Commented] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785956#comment-17785956 ] Kamal Chandraprakash commented on KAFKA-15376: -- [~divijvaidya]  The

[jira] [Assigned] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-15376: Assignee: Satish Duggana (was: Kamal Chandraprakash) > Explore options

[jira] [Resolved] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-15376. -- Resolution: Fixed This task was already addressed in the code, so closing the

[jira] [Assigned] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash reassigned KAFKA-15376: Assignee: Kamal Chandraprakash > Explore options of removing data

[jira] [Updated] (KAFKA-13563) FindCoordinatorFuture never get cleared in non-group mode( consumer#assign)

[ https://issues.apache.org/jira/browse/KAFKA-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-13563: - Affects Version/s: 2.8.2 > FindCoordinatorFuture never get cleared in non-group

[jira] [Updated] (KAFKA-15776) Configurable delay timeout for DelayedRemoteFetch request

[ https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15776: - Description: We are reusing the {{fetch.max.wait.ms}} config as a delay timeout

[jira] [Updated] (KAFKA-15776) Configurable delay timeout for DelayedRemoteFetch request

[ https://issues.apache.org/jira/browse/KAFKA-15776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15776: - Description: We are reusing the {{fetch.max.wait.ms}} config as a delay timeout

[jira] [Updated] (KAFKA-15777) Configurable remote fetch bytes per partition from Consumer

[ https://issues.apache.org/jira/browse/KAFKA-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash updated KAFKA-15777: - Description: A consumer can configure the amount of local bytes to read from

  1   2   3   >