THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
magic: int16 (current magic value is 0) length: int16 (length of this entry) crc: int32 (checksum from firstOffset to the end of this entry) firstOffset: int64 (the Kafka offset of the 1st record) lastOffset: int64 (the Kafka offset of the last record) firstTimestamp: int64 lastTimestamp: int64 dataLength: int32 (length of the remote data) rdiLength: int16 rdi: byte[] (Remote data identifier) |
todo: We may change this format to have magic and crc for a batch of entries instead of having them for each entry.
RDI (Remote data identifier) is the "pointer" or "URI" of the remote data. The format of RDI depends on the implementation. For example, RDI can be HDFS file path and offset, or S3 key and offset. When reading the remote records, RLM will use RDI to retrieve the remote data.
...
- the follower received the corresponding segment data info from a remote storage and updated its index files and
- the local files are already older than the configured remote retention time
...