kamalcph commented on PR #14301:
URL: https://github.com/apache/kafka/pull/14301#issuecomment-1695539631
### Test Report
```scala
[SUCCESS] (1) create topic: Topic[name=topicA partition-count=1
replication-factor=1 segment-size=1 assignment=null
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=k1, value=v1, timestamp=null)
ProducerRecord(topic=topicA, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k2, value=v2, timestamp=null)
ProducerRecord(topic=topicA, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k3, value=v3, 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) create topic: Topic[name=topicB partition-count=1
replication-factor=1 segment-size=2 assignment=null
properties={remote.storage.enable=true, local.retention.bytes=1,
index.interval.bytes=1, segment.index.bytes=24}]
[SUCCESS] (4) produce-records: topicB-0
ProducerRecord(topic=topicB, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k1, value=v1, timestamp=null)
ProducerRecord(topic=topicB, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k2, value=v2, timestamp=null)
ProducerRecord(topic=topicB, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k3, value=v3, timestamp=null)
ProducerRecord(topic=topicB, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k4, value=v4, timestamp=null)
ProducerRecord(topic=topicB, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k5, value=v5, timestamp=null)
Segment[partition=topicB-0 offloaded-by-broker-id=0 base-offset=0
record-count=2]
Segment[partition=topicB-0 offloaded-by-broker-id=0 base-offset=2
record-count=2]
[SUCCESS] (5) bounce-broker: 0
[SUCCESS] (6) consume-action:
topic-partition = topicA-0
fetch-offset = 1
expected-record-count = 2
expected-record-from-tiered-storage = 1
[SUCCESS] (7) consume-action:
topic-partition = topicB-0
fetch-offset = 1
expected-record-count = 4
expected-record-from-tiered-storage = 3
Content of local tiered storage:
Broker IDFile | Offsets | Records
----------------------------------------------------------------------------------------
topicB-0 | |
00000000000000000000-ZYHNDiMkQAuKx_Hm7yettA.log | 0 | (k1, v1)
| 1 | (k2, v2)
| |
00000000000000000002-404zVl_XTuCyOEBrnEVxvQ.log | 2 | (k3, v3)
| 3 | (k4, v4)
| |
topicA-0 | |
00000000000000000001-dwVJFEg8SmqzcKuJrD0C8w.log | 1 | (k2, v2)
| |
00000000000000000000-dYoeCs5FSKSEekm7aBq3aQ.log | 0 | (k1, v1)
| |
```
--
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
