[
https://issues.apache.org/jira/browse/KAFKA-20148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18057507#comment-18057507
]
Kamal Chandraprakash commented on KAFKA-20148:
----------------------------------------------
[~dyingjiecai]
Could you add more details on the data loss that you're observing? If you want
to preserve the remote data while disabling remote storag, then use
{{remote.storage.enable=true,remote.log.copy.disable=true}} setting.
> Data Loss Risk When Disabling Remote Storage Due to Race Condition
> ------------------------------------------------------------------
>
> Key: KAFKA-20148
> URL: https://issues.apache.org/jira/browse/KAFKA-20148
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 3.8.0, 3.8.1, 3.9.0, 3.9.1, 4.0.0, 4.0.1, 4.1.0, 4.1.1
> Reporter: dyingjiecai
> Priority: Major
>
> # Summary
> When disabling remote log storage (`remote.storage.enable=true` → `false`)
> with
> `remote.log.delete.on.disable=true`, there is a race condition between
> `RLMExpirationTask` and `ConfigHandler` that can lead to premature deletion
> of
> local log segments, resulting in **data loss**.
> # Affected Versions
> Kafka 3.0+ (all versions with tiered storage support)
> # Severity
> Critical - Data Loss
> # Root Cause Analysis
> ## Simplified Flow
> Cancel Tasks → Reset Offset → [RACE!] → Task Updates Offset → Delete Data
> ↑___________________________________________|
> ## Key Issues
> 1. **stopPartitions() returns immediately after canceling tasks** - does
> not wait
> for RLMExpirationTask to complete
> 2. **Task cancellation is not checked during execution** - RLMExpirationTask
> continues running after cancel() is called
> 3. **deleteRemoteLogPartition() executes before tasks stop** - while tasks
> may
> still be accessing remote storage
> # logs
> server.log:2026-02-06
> 15:14:37.180|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.server.ZkConfigManager(66):
> Processing override for entityPath: topics/topic_for_broker_remote_test17
> with config: HashMap(local.retention.ms -> -2, remote.log.delete.on.disable
> -> false, remote.storage.enable -> true, local.retention.bytes -> -2,
> retention.ms -> 36000000, remote.log.copy.disable -> false)
> server.log:2026-02-06
> 15:14:37.181|1|INFO|[,,,,,]|/config/changes-event-process-thread|org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager(290):
> Received leadership notifications with leader partitions [] and follower
> partitions [gtVl3Y5wRZ-jIM_2p5j7Fg:topic_for_broker_remote_test17-2]
> server.log:2026-02-06
> 15:14:37.181|1|INFO|[,,,,,]|/config/changes-event-process-thread|org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask(311):
> Updating assignments for partitions added:
> [gtVl3Y5wRZ-jIM_2p5j7Fg:topic_for_broker_remote_test17-2] and removed: []
> server.log:2026-02-06
> 15:14:37.181|1|INFO|[,,,,,]|/config/changes-event-process-thread|org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask(311):
> Updating assignments for partitions added:
> [gtVl3Y5wRZ-jIM_2p5j7Fg:topic_for_broker_remote_test17-2] and removed: []
> server.log:2026-02-06
> 15:14:37.181|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.server.TopicQuotaManager(66):
> Removing PRODUCE quota for topic_for_broker_remote_test17
> server.log:2026-02-06
> 15:14:37.181|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.server.TopicTpsQuotaManager(66):
> Removing PRODUCE_TPS quota for topic_for_broker_remote_test17
> server.log:2026-02-06
> 15:14:37.181|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.server.TopicQuotaManager(66):
> Removing FETCH quota for topic_for_broker_remote_test17
> server.log:2026-02-06
> 15:14:37.181|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.server.TopicTpsQuotaManager(66):
> Removing FETCH_TPS quota for topic_for_broker_remote_test17
> server.log:2026-02-06
> 15:14:37.184|1|INFO|[,,,,,]|ReplicaFetcherThread-1-1|kafka.log.UnifiedLog(66):
> [UnifiedLog partition=topic_for_broker_remote_test17-2,
> dir=/var/lib/kafka/data-0/kafka-log0] Incremented log start offset to 3123750
> due to leader offset increment
> server.log:2026-02-06
> 15:14:55.354|1|INFO|[,,,,,]|ReplicaFetcherThread-1-1|kafka.log.LocalLog(66):
> [LocalLog partition=topic_for_broker_remote_test17-2,
> dir=/var/lib/kafka/data-0/kafka-log0] Rolled new log segment at offset
> 3436125 in 0 ms.
> server.log:2026-02-06
> 15:14:55.355|1|INFO|[,,,,,]|ReplicaFetcherThread-1-1|org.apache.kafka.storage.internals.log.ProducerStateManager(471):
> [ProducerStateManager partition=topic_for_broker_remote_test17-2] Wrote
> producer snapshot at offset 3436125 with 0 producer ids in 0 ms.
> server.log:2026-02-06
> 15:16:37.068|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.server.ZkConfigManager(66):
> Processing override for entityPath: topics/topic_for_broker_remote_test17
> with config: HashMap(local.retention.ms -> -2, remote.log.delete.on.disable
> -> true, remote.storage.enable -> false, local.retention.bytes -> -2,
> retention.ms -> 36000000, remote.log.copy.disable -> false)
> server.log:2026-02-06
> 15:16:37.068|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.log.remote.RemoteLogManager(579):
> Cancelling the follower RLM task for tpId:
> gtVl3Y5wRZ-jIM_2p5j7Fg:topic_for_broker_remote_test17-2
> server.log:2026-02-06
> 15:16:37.068|1|INFO|[,,,,,]|/config/changes-event-process-thread|org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask(311):
> Updating assignments for partitions added: [] and removed:
> [gtVl3Y5wRZ-jIM_2p5j7Fg:topic_for_broker_remote_test17-2]
> server.log:2026-02-06
> 15:16:37.068|1|INFO|[,,,,,]|/config/changes-event-process-thread|org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask(311):
> Updating assignments for partitions added: [] and removed:
> [gtVl3Y5wRZ-jIM_2p5j7Fg:topic_for_broker_remote_test17-2]
> server.log:2026-02-06
> 15:16:37.068|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.server.TopicQuotaManager(66):
> Removing PRODUCE quota for topic_for_broker_remote_test17
> server.log:2026-02-06
> 15:16:37.069|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.server.TopicTpsQuotaManager(66):
> Removing PRODUCE_TPS quota for topic_for_broker_remote_test17
> server.log:2026-02-06
> 15:16:37.069|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.server.TopicQuotaManager(66):
> Removing FETCH quota for topic_for_broker_remote_test17
> server.log:2026-02-06
> 15:16:37.069|1|INFO|[,,,,,]|/config/changes-event-process-thread|kafka.server.TopicTpsQuotaManager(66):
> Removing FETCH_TPS quota for topic_for_broker_remote_test17
> server.log:2026-02-06
> 15:19:19.193|1|INFO|[,,,,,]|kafka-scheduler-3|kafka.log.UnifiedLog(66):
> [UnifiedLog partition=topic_for_broker_remote_test17-2,
> dir=/var/lib/kafka/data-0/kafka-log0] Deleting segments due to log start
> offset 3123750 breach: LogSegment(baseOffset=0, size=1073737000,
> lastModifiedTime=1770344986807,
> largestRecordTimestamp=1770344986806),LogSegment(baseOffset=104125,
> size=1073737000, lastModifiedTime=1770345520193,
> largestRecordTimestamp=1770345520193),LogSegment(baseOffset=208250,
> size=1073737000, lastModifiedTime=1770346052466,
> largestRecordTimestamp=1770346052465),LogSegment(baseOffset=312375,
> size=1073737000, lastModifiedTime=1770346585663,
> largestRecordTimestamp=1770346585662),LogSegment(baseOffset=416500,
> size=1073737000, lastModifiedTime=1770347119954,
> largestRecordTimestamp=1770347119953),LogSegment(baseOffset=520625,
> size=1073737000, lastModifiedTime=1770347654146,
> largestRecordTimestamp=1770347654144),LogSegment(baseOffset=624750,
> size=1073737000, lastModifiedTime=1770348187335,
> largestRecordTimestamp=1770348187335),LogSegment(baseOffset=728875,
> size=1073737000, lastModifiedTime=1770348720169,
> largestRecordTimestamp=1770348720169),LogSegment(baseOffset=833000,
> size=1073737000, lastModifiedTime=1770349254443,
> largestRecordTimestamp=1770349254442),LogSegment(baseOffset=937125,
> size=1073737000, lastModifiedTime=1770349788278,
> largestRecordTimestamp=1770349788278),LogSegment(baseOffset=1041250,
> size=1073737000, lastModifiedTime=1770350321069,
> largestRecordTimestamp=1770350321069),LogSegment(baseOffset=1145375,
> size=1073737000, lastModifiedTime=1770350856955,
> largestRecordTimestamp=1770350856954),LogSegment(baseOffset=1249500,
> size=1073737000, lastModifiedTime=1770351390585,
> largestRecordTimestamp=1770351390584),LogSegment(baseOffset=1353625,
> size=1073737000, lastModifiedTime=1770351922834,
> largestRecordTimestamp=1770351922833),LogSegment(baseOffset=1457750,
> size=1073737000, lastModifiedTime=1770352457713,
> largestRecordTimestamp=1770352457712),LogSegment(baseOffset=1561875,
> size=1073737000, lastModifiedTime=1770352990842,
> largestRecordTimestamp=1770352990843),LogSegment(baseOffset=1666000,
> size=1073737000, lastModifiedTime=1770353524425,
> largestRecordTimestamp=1770353524425),LogSegment(baseOffset=1770125,
> size=1073737000, lastModifiedTime=1770354058535,
> largestRecordTimestamp=1770354058534),LogSegment(baseOffset=1874250,
> size=1073737000, lastModifiedTime=1770354594136,
> largestRecordTimestamp=1770354594135),LogSegment(baseOffset=1978375,
> size=1073737000, lastModifiedTime=1770355129971,
> largestRecordTimestamp=1770355129971),LogSegment(baseOffset=2082500,
> size=1073737000, lastModifiedTime=1770355665214,
> largestRecordTimestamp=1770355665213),LogSegment(baseOffset=2186625,
> size=1073737000, lastModifiedTime=1770356198872,
> largestRecordTimestamp=1770356198872),LogSegment(baseOffset=2290750,
> size=1073737000, lastModifiedTime=1770356733299,
> largestRecordTimestamp=1770356733298),LogSegment(baseOffset=2394875,
> size=1073737000, lastModifiedTime=1770357269074,
> largestRecordTimestamp=1770357269073),LogSegment(baseOffset=2499000,
> size=1073737000, lastModifiedTime=1770357803069,
> largestRecordTimestamp=1770357803069),LogSegment(baseOffset=2603125,
> size=1073737000, lastModifiedTime=1770358342005,
> largestRecordTimestamp=1770358342004),LogSegment(baseOffset=2707250,
> size=1073737000, lastModifiedTime=1770358880283,
> largestRecordTimestamp=1770358880282),LogSegment(baseOffset=2811375,
> size=1073737000, lastModifiedTime=1770359416232,
> largestRecordTimestamp=1770359416231),LogSegment(baseOffset=2915500,
> size=1073737000, lastModifiedTime=1770359952425,
> largestRecordTimestamp=1770359952424),LogSegment(baseOffset=3019625,
> size=1073737000, lastModifiedTime=1770360488231,
> largestRecordTimestamp=1770360488230)
> server.log:2026-02-06
> 15:20:19.195|1|INFO|[,,,,,]|kafka-scheduler-8|kafka.log.LocalLog$(573):
> [LocalLog partition=topic_for_broker_remote_test17-2,
> dir=/var/lib/kafka/data-0/kafka-log0] Deleting segment files
> LogSegment(baseOffset=0, size=1073737000, lastModifiedTime=1770344986807,
> largestRecordTimestamp=1770344986806),LogSegment(baseOffset=104125,
> size=1073737000, lastModifiedTime=1770345520193,
> largestRecordTimestamp=1770345520193),LogSegment(baseOffset=208250,
> size=1073737000, lastModifiedTime=1770346052466,
> largestRecordTimestamp=1770346052465),LogSegment(baseOffset=312375,
> size=1073737000, lastModifiedTime=1770346585663,
> largestRecordTimestamp=1770346585662),LogSegment(baseOffset=416500,
> size=1073737000, lastModifiedTime=1770347119954,
> largestRecordTimestamp=1770347119953),LogSegment(baseOffset=520625,
> size=1073737000, lastModifiedTime=1770347654146,
> largestRecordTimestamp=1770347654144),LogSegment(baseOffset=624750,
> size=1073737000, lastModifiedTime=1770348187335,
> largestRecordTimestamp=1770348187335),LogSegment(baseOffset=728875,
> size=1073737000, lastModifiedTime=1770348720169,
> largestRecordTimestamp=1770348720169),LogSegment(baseOffset=833000,
> size=1073737000, lastModifiedTime=1770349254443,
> largestRecordTimestamp=1770349254442),LogSegment(baseOffset=937125,
> size=1073737000, lastModifiedTime=1770349788278,
> largestRecordTimestamp=1770349788278),LogSegment(baseOffset=1041250,
> size=1073737000, lastModifiedTime=1770350321069,
> largestRecordTimestamp=1770350321069),LogSegment(baseOffset=1145375,
> size=1073737000, lastModifiedTime=1770350856955,
> largestRecordTimestamp=1770350856954),LogSegment(baseOffset=1249500,
> size=1073737000, lastModifiedTime=1770351390585,
> largestRecordTimestamp=1770351390584),LogSegment(baseOffset=1353625,
> size=1073737000, lastModifiedTime=1770351922834,
> largestRecordTimestamp=1770351922833),LogSegment(baseOffset=1457750,
> size=1073737000, lastModifiedTime=1770352457713,
> largestRecordTimestamp=1770352457712),LogSegment(baseOffset=1561875,
> size=1073737000, lastModifiedTime=1770352990842,
> largestRecordTimestamp=1770352990843),LogSegment(baseOffset=1666000,
> size=1073737000, lastModifiedTime=1770353524425,
> largestRecordTimestamp=1770353524425),LogSegment(baseOffset=1770125,
> size=1073737000, lastModifiedTime=1770354058535,
> largestRecordTimestamp=1770354058534),LogSegment(baseOffset=1874250,
> size=1073737000, lastModifiedTime=1770354594136,
> largestRecordTimestamp=1770354594135),LogSegment(baseOffset=1978375,
> size=1073737000, lastModifiedTime=1770355129971,
> largestRecordTimestamp=1770355129971),LogSegment(baseOffset=2082500,
> size=1073737000, lastModifiedTime=1770355665214,
> largestRecordTimestamp=1770355665213),LogSegment(baseOffset=2186625,
> size=1073737000, lastModifiedTime=1770356198872,
> largestRecordTimestamp=1770356198872),LogSegment(baseOffset=2290750,
> size=1073737000, lastModifiedTime=1770356733299,
> largestRecordTimestamp=1770356733298),LogSegment(baseOffset=2394875,
> size=1073737000, lastModifiedTime=1770357269074,
> largestRecordTimestamp=1770357269073),LogSegment(baseOffset=2499000,
> size=1073737000, lastModifiedTime=1770357803069,
> largestRecordTimestamp=1770357803069),LogSegment(baseOffset=2603125,
> size=1073737000, lastModifiedTime=1770358342005,
> largestRecordTimestamp=1770358342004),LogSegment(baseOffset=2707250,
> size=1073737000, lastModifiedTime=1770358880283,
> largestRecordTimestamp=1770358880282),LogSegment(baseOffset=2811375,
> size=1073737000, lastModifiedTime=1770359416232,
> largestRecordTimestamp=1770359416231),LogSegment(baseOffset=2915500,
> size=1073737000, lastModifiedTime=1770359952425,
> largestRecordTimestamp=1770359952424),LogSegment(baseOffset=3019625,
> size=1073737000, lastModifiedTime=1770360488231,
> largestRecordTimestamp=1770360488230)
> server.log:2026-02-06
> 15:20:19.195|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000000104125.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.195|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000000208250.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000000312375.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000000416500.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000000520625.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000000624750.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000000728875.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000000833000.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000000937125.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000001041250.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000001145375.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000001249500.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000001353625.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000001457750.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000001561875.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000001666000.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000001770125.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000001874250.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000001978375.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000002082500.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000002186625.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000002290750.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000002394875.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000002499000.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000002603125.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000002707250.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000002811375.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000002915500.snapshot.deleted
> server.log:2026-02-06
> 15:20:19.196|1|INFO|[,,,,,]|kafka-scheduler-6|org.apache.kafka.storage.internals.log.SnapshotFile(48):
> Deleted producer state snapshot
> /var/lib/kafka/data-0/kafka-log0/topic_for_broker_remote_test17-2/00000000000003019625.snapshot.deleted
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
