private static String decodeUserEndpoint(final ByteBuffer data) {
        final int userEndpointBytesLength = data.getInt();
        final byte[] userEndpointBytes = new byte[userEndpointBytesLength];
        data.get(userEndpointBytes);
        return new String(userEndpointBytes, StandardCharsets.UTF_8);
    }
@throws TaskAssignmentException if method fails to decode the data
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacySubscriptionInfoSerde.java