public class FileTierPartitionStateUtils extends Object
Constructor and Description |
---|
FileTierPartitionStateUtils() |
Modifier and Type | Method and Description |
---|---|
static TierObjectMetadata |
read(TopicIdPartition topicIdPartition,
CheckedFileIO channel,
long position)
Perform a point read of a TierObjectMetadata at a particular position in a
TierPartitionState's CheckedFileIO instance
|
public static TierObjectMetadata read(TopicIdPartition topicIdPartition, CheckedFileIO channel, long position) throws org.apache.kafka.common.errors.KafkaStorageException
topicIdPartition
- TopicIdPartition for the channel being readchannel
- CheckedFileIO instanceposition
- Byte position of the metadata to be readorg.apache.kafka.common.errors.KafkaStorageException
- thrown when a validation error or IOException is encountered