dyingjiecai created KAFKA-20148:
-----------------------------------
Summary: 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: 4.1.1, 4.1.0, 4.0.1, 4.0.0, 3.9.1, 3.9.0, 3.8.1, 3.8.0
Reporter: dyingjiecai
### 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)
