kamalcph commented on PR #14307:
URL: https://github.com/apache/kafka/pull/14307#issuecomment-1696893297
### PartitionsExpandTest Report
```scala
[SUCCESS] (1) create topic: Topic[name=topicA partition-count=1
replication-factor=2 segment-size=1 assignment={0=[0, 1]}
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) create-partitions: ExpandPartitionCountSpec[topicName=topicA,
partitionCount=3, assignment={1=[0, 1], 2=[1, 0]}]
[SUCCESS] (4) consume-action:
topic-partition = topicA-0
fetch-offset = 0
expected-record-count = 3
expected-record-from-tiered-storage = 2
[SUCCESS] (5) expect-leader: topic-partition: topicA-1, replicaId: 0,
electLeader: false
[SUCCESS] (6) expect-leader: topic-partition: topicA-2, replicaId: 1,
electLeader: false
[SUCCESS] (7) 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=0 base-offset=0
record-count=1]
Segment[partition=topicA-1 offloaded-by-broker-id=0 base-offset=1
record-count=1]
[SUCCESS] (8) produce-records: topicA-2
ProducerRecord(topic=topicA, partition=2, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k0, value=v0, timestamp=null)
ProducerRecord(topic=topicA, partition=2, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k1, value=v1, timestamp=null)
ProducerRecord(topic=topicA, partition=2, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k2, value=v2, timestamp=null)
Segment[partition=topicA-2 offloaded-by-broker-id=1 base-offset=0
record-count=1]
Segment[partition=topicA-2 offloaded-by-broker-id=1 base-offset=1
record-count=1]
[SUCCESS] (9) produce-records: topicA-0
ProducerRecord(topic=topicA, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k3, value=v3, timestamp=null)
ProducerRecord(topic=topicA, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k4, value=v4, timestamp=null)
ProducerRecord(topic=topicA, partition=0, headers=RecordHeaders(headers
= [], isReadOnly = true), key=k5, value=v5, timestamp=null)
Segment[partition=topicA-0 offloaded-by-broker-id=0 base-offset=3
record-count=1]
Segment[partition=topicA-0 offloaded-by-broker-id=0 base-offset=4
record-count=1]
[SUCCESS] (10) consume-action:
topic-partition = topicA-0
fetch-offset = 0
expected-record-count = 6
expected-record-from-tiered-storage = 5
[SUCCESS] (11) consume-action:
topic-partition = topicA-1
fetch-offset = 0
expected-record-count = 3
expected-record-from-tiered-storage = 2
[SUCCESS] (12) consume-action:
topic-partition = topicA-2
fetch-offset = 1
expected-record-count = 2
expected-record-from-tiered-storage = 1
Content of local tiered storage:
Broker IDFile | Offsets | Records
----------------------------------------------------------------------------------------
topicA-2 | |
00000000000000000001-TiygcgBrTDma-MXLyerzkQ.log | 1 | (k1, v1)
| |
00000000000000000000-IY_ZJfQRSj2GbL4mjCZPdQ.log | 0 | (k0, v0)
| |
topicA-1 | |
00000000000000000000-F7i40B5rQPmCmBjDAnsEHw.log | 0 | (k0, v0)
| |
00000000000000000001-zVyeIx9WQ5mfd5tvDrW1cQ.log | 1 | (k1, v1)
| |
topicA-0 | |
00000000000000000003-NArRT1ueTxCZeFkDP_PJIw.log | 3 | (k3, v3)
| |
00000000000000000002-QZHcZK-SRh6i1JgZJCp8bA.log | 2 | (k2, v2)
| |
00000000000000000004-r4ycZbBvTOSeQYpDybAm1w.log | 4 | (k4, v4)
| |
00000000000000000000-RM48dExjQJGCESfEtNoD3g.log | 0 | (k0, v0)
| |
00000000000000000001-ff2P80Q5Tm6142NN96EsfQ.log | 1 | (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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
