SourceMessage

constructor(offset: Long, key: String?, headers: Map<String, String>, value: ByteArray)