StreamPublishPartition
scala.Option<String>
checksum()
scala.Option<Object>
compressedDataSize()
crc()
dataSize()
String
layer()
partition()
timestamp()