kamalcph commented on PR #14307:
URL: https://github.com/apache/kafka/pull/14307#issuecomment-1696897781
### DeleteTopicWithSecondaryStorageTest Report
```scala
[SUCCESS] (1) create topic: Topic[name=topicA partition-count=2
replication-factor=2 segment-size=1 assignment={0=[0, 1], 1=[1, 0]}
properties={remote.storage.enable=true, local.retention.bytes=1,
index.interval.bytes=1, segment.index.bytes=12}]
[SUCCESS] (2) produce-records: topicA-0
ProducerRecord(topic=topicA, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k0, value=v0, timestamp=null)
ProducerRecord(topic=topicA, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k1, value=v1, timestamp=null)
ProducerRecord(topic=topicA, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k2, value=v2, timestamp=null)
Segment[partition=topicA-0 offloaded-by-broker-id=0 base-offset=0
record-count=1]
Segment[partition=topicA-0 offloaded-by-broker-id=0 base-offset=1
record-count=1]
[SUCCESS] (3) produce-records: topicA-1
ProducerRecord(topic=topicA, partition=1, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k0, value=v0, timestamp=null)
ProducerRecord(topic=topicA, partition=1, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k1, value=v1, timestamp=null)
ProducerRecord(topic=topicA, partition=1, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k2, value=v2, timestamp=null)
Segment[partition=topicA-1 offloaded-by-broker-id=1 base-offset=0
record-count=1]
Segment[partition=topicA-1 offloaded-by-broker-id=1 base-offset=1
record-count=1]
[SUCCESS] (4) delete-topic: topicA
RemoteDeleteSegment[source-broker-id=1 topic-partition=topicA-1
event-type=DELETE_SEGMENT event-count=2]
RemoteDeleteSegment[source-broker-id=0 topic-partition=topicA-0
event-type=DELETE_SEGMENT event-count=2]
Content of local tiered storage:
Broker IDFile | Offsets | Records
----------------------------------------------------------------------------------------
topicA-1 | |
topicA-0 | |
Condition not met within timeout 2000. Remote storage is not empty for
topicA-0 ==> expected: <true> but was: <false>
Expected :true
Actual :false
```
The test failed at action-5 where we expect the remote storage to be empty.
Since, we don't differentiate the case between deleting remote log segments due
to retention size/time/log-start-offset breach and topic deletion. The
underlying remote-storage-manager have no way to remove any marker folders. In
this case, topic-partition directory.
Will update the test to ignore empty partition directories.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
