public int getSubpartitionId() {
        return subpartitionId;
    }
@Test
    void testGetSubpartitionId() {
        Buffer buffer = BufferBuilderTestUtils.buildSomeBuffer(0);
        int bufferIndex = 0;
        int subpartitionId = 1;
        NettyPayload nettyPayload = NettyPayload.newBuffer(buffer, bufferIndex, subpartitionId);
        assertThat(nettyPayload.getSubpartitionId()).isEqualTo(subpartitionId);
    }