'0 for CreateTime; 1 for LogAppendTime; None if unsupported.
Value is determined by broker; produced messages should always set to 0
Requires Kafka >= 0.10 / message version >= 1'

@property
def timestamp_type(self):

    if (self.magic == 0):
        return None
    elif (self.attributes & self.TIMESTAMP_TYPE_MASK):
        return 1
    else:
        return 0
