private void testEquivalentMessageRoundTrip(short version, Message message) throws Exception {
        testByteBufferRoundTrip(version, message, message);
        testJsonRoundTrip(version, message, message);
    }
@param startVersion - the version we want to start at, inclusive
@param endVersion - the version we want to end at, exclusive
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java