protected ByteBuffer getByteBuffer(byte[] payload) {
        if (payload == null || payload.length < HEADER_SIZE) {
            throw new SerializationException("Invalid payload size");
        }
        ByteBuffer buffer = ByteBuffer.wrap(payload);
        byte magicByte = buffer.get();
        if (magicByte != MAGIC_BYTE) {
            throw new SerializationException("Unknown magic byte: " + magicByte);
        }
        return buffer;
    }
Phase 2a: Process the header of the message

@param payload The serialized payload
@return ByteBuffer positioned after the magic byte
core/src/main/java/kafka/automq/table/deserializer/proto/AbstractCustomKafkaProtobufDeserializer.java